本文为您介绍如何增加一个复合类型。 增加一个复合类型 teledb create type mytype as (f1 int,f2 varchar(10)); CREATE TYPE

创建jsonb类型字段表 teledb create table tjsonb(id int,fjsonb jsonb); CREATE TABLE 插入数据 teledb insert into tjsonb values(1,'{"col1":1,"col2":"teledb"}'); INSERT 0 1 teledb insert into tjsonb values(2,'{"col1":1,"col2":"teledb","col3":"pgxz"}'); INSERT 0 1 teledb select from tjsonb; id fjsonb + 1 {"col1": 1, "col2": "teledb"} 2 {"col1": 1, "col2": "teledb", "col3": "pgxz"} (2 rows jsonb插入时会移除重复的键，如下所示。 teledb insert into tjsonb values(3,'{"col1":1,"col2":"teledb","col2":"pgxz"}'); INSERT 0 1 teledb select from tjsonb; id fjsonb + 1 {"col1": 1, "col2": "teledb"} 2 {"col1": 1, "col2": "teledb", "col3": "pgxz"} 3 {"col1": 1, "col2": "pgxz"} (3 rows) 更新数据 增加元素。 teledb update tjsonb set fjsonb fjsonb '{"col3":"pgxz"}'::jsonb where id1; UPDATE 1 teledb select from tjsonb; id fjsonb + 2 {"col1": 1, "col2": "teledb", "col3": "pgxz"} 1 {"col1": 1, "col2": "teledb", "col3": "pgxz"} 3 {"col1": 1, "col2": "pgxz"} (3 rows) 更新原来的元素。 teledb

创建json 类型字段表 teledb create table tjson(id int,fjson json); CREATE TABLE 插入数据 teledb insert into tjson values(1,'{"col1":1,"col2":"teledb"}'); INSERT 0 1 teledb insert into tjson values(2,'{"col1":1,"col2":"teledb","col3":"pgxz"}'); INSERT 0 1 teledb select from tjson; id fjson + 1 {"col1":1,"col2":"teledb"} 2 {"col1":1,"col2":"teledb","col3":"pgxz"} (2 rows) 通过键获得json对象域 teledb select fjson >'col2' as col2 ,fjson > 'col3' as col3 from tjson; col2 col3 + "teledb" "teledb" "pgxz" (2 rows) 以文本形式获取对象值 teledb select fjson >>'col2' as col2 ,fjson >> 'col3' as col3 from tjson; col2 col3 + teledb teledb pgxz (2 rows) teledb select fjson >>'col2' as col2 ,fjson >> 'col3' as col3 from tjson where fjson >> 'col3' is not null; col2 col3 + teledb pgxz (1 row)

本文介绍如何在使用SELECT语法时进行聚合函数并发计算。 teledb set maxparallelworkerspergather to 0; SET Time: 0.214 ms teledb select count(1) from tcount; count 20000000 (1 row) Time: 2700.569 ms (00:02.701) teledb set maxparallelworkerspergather to 2; SET Time: 0.269 ms teledb select count(1) from tcount; count 20000000 (1 row) Time: 1867.719 ms (00:01.868)

本文介绍如何在使用SELECT语法时，返回两个结果的交集。 teledb select from teledbpg intersect select from teledbpg1; id nickname + 3 pg (1 row)

本文介绍如何在使用SELECT语法时，返回两个结果的差集。 teledb select from teledbpg except select from teledbpg1; id nickname + 2 TELEDB 4 1 teledb 1 hello,pgxc (4 rows)

本文为您介绍如何管理视图，包括创建视图、删除视图和物化视图使用。 创建视图 teledb create view trangeview as select from trange; CREATE VIEW teledb select from trangeview; f1 f2 f3 ++ 1 20230822 11:06:16.9783 1 2 20230822 11:06:16.9783 50 2 20230822 11:06:16.9783 110 3 20230822 11:06:16.9783 100 (4 rows) 数据类型重定义。 teledb drop view trangeview; DROP VIEW teledb create view trangeview as select f1,f2::date from trange; CREATE VIEW teledb select from trangeview; f1 f2 + 1 20230822 3 20230822 2 20230822 2 20230822 (4 rows) 数据类型重定义，以及取别名。 teledb drop view trangeview; DROP VIEW teledb create view trangeview as select f1,f2::date as mydate from trange; CREATE VIEW teledb select from trangeview; f1 mydate + 1 20230822 2 20230822 2 20230822 3 20230822 (4 rows) TeleDB 支持视图引用表或字段改名联动，不受影响。 teledb d+ trangeview View "teledb.trangeview" Column Type Collation Nullable Default Storage Description ++++++ f1 bigint plain mydate date plain View definition: SELECT trange.f1, trange.f2::date AS mydate FROM trange; teledb

本文为您介绍如何管理分区表全局索引。 支持创建分区表全局索引，目前仅支持btree索引类型 建表 CREATE TABLE parentrangetbl( c1 int not null, c2 int not null, c3 int not null ) PARTITION BY RANGE (c1); CREATE TABLE part0100 PARTITION OF parentrangetbl FOR VALUES FROM (0) TO (100); CREATE TABLE part100200 PARTITION OF parentrangetbl FOR VALUES FROM (100) TO (200); CREATE TABLE partdefault PARTITION OF parentrangetbl DEFAULT; 插入数据 INSERT INTO parentrangetbl(c1,c2,c3) SELECT generateseries(50, 100) AS c1, generateseries(50, 100) AS c2, generateseries(50, 100) AS c3; 创建全局索引 CREATE INDEX c3globalidx ON parentrangetbl(c3) GLOBAL; 设置不使用seq scan set enableseqscan TO off; 通过全局索引查询数据 EXPLAIN SELECT c3 FROM parentrangetbl WHERE c3 > 70 AND c3 Index Only Scan using c3globalidx on parentrangetbl (cost0.12..8.14 rows9 width4) Index Cond: ((c3 > 70) AND (c3 < 75)) (3 rows)

本文为您介绍如何创建唯一索引。 创建唯一索引 teledb create unique index tasiduidx on tas using btree(id); CREATE INDEX 非shard key 字段不能建立唯一索引 teledb create unique index tasiduidx on tas using btree(mc); ERROR: Unique index of partitioned table must contain the hash/modulo distribution column.

本页为您介绍如何使用使用 IF NOT EXISTS关键字。 带IF NOT EXISTS 关键字作用表示表不存在时才创建。 teledb create table t(id int,mc text); CREATE TABLE teledb create table t(id int,mc text); ERROR: relation "t" already exists teledb create table IF NOT EXISTS t(id int,mc text); NOTICE: relation "t" already exists, skipping CREATE TABLE

d+ tnativemullistgd Table "public.tnativemullistgd" Column Type Collation Nullable Default Storage Stats target Description ++++++ + f1 bigint not null nextval('tnativemullistf1seq'::regclass) plain f2 integer plain f3 text extended f4 text extended f5 timestamp(0) without time zone plain Partition of: tnativemullist FOR VALUES IN ('广东') Partition constraint: ((f3 IS NOT NULL) AND (f3 ANY (ARRAY['广东'::text]))) Partition key: RANGE (f5) Partitions: tnativemullistgd201701 FOR VALUES FROM ('20170101 00:00:00') TO ('20170201 00:00:00'), tnativemullistgd201702 FOR VALUES FROM ('20170201 00:00:00') TO ('20170301 00:00:00') Distribute By: SHARD(f1) Location Nodes: ALL DATANODES TeleDB支持存在1级和2级分区混用，大家不需要都平级。

insert into public.t3 values(1,'test'); INSERT 0 1 由于teledb模式在第一顺位，且存在同名表，所以始终是teledb模式下的空表 teledb select from t3; id content + (0 rows) 指定public模式去查询可以查到插入的数据 teledb select from public.t3; id content + 1 test (1 row) 访问不在搜索路径的对象时，需要写全路径。 teledb create table test1.t4 (id int, name char); CREATE TABLE teledb select from t4; ERROR: relation "t4" does not exist LINE 1: select from t4; ^ teledb select from test1.t4; id name + (0 rows) 上面出错是因为模式test1没有配置在searchpath搜索路径中。

本文为您介绍如何修改模式属性。 您可参考如下操作修改模式属性。 修改模式名 teledb alter schema teledbschema rename to teledbschemanew; ALTER SCHEMA 修改所有者 teledb dn teledbschemanew List of schemas Name Owner + teledbschemanew teledb (1 row) teledb alter schema teledbschemanew owner to teledbuser; ALTER SCHEMA teledb dn teledbschemanew List of schemas Name Owner + teledbschemanew teledbuser (1 row)

本文为您介绍如何删除数据库。 删除数据库teledbdbnew teledb drop database teledbdbnew; 仍有会话连接数据库时，会报错 ERROR: database "teledbdbnew" is being accessed by other users DETAIL: There is 1 other session using the database. 停止该数据库的所有连接后重新删除数据库 teledb select pgterminatebackend(pid) from pgstatactivity where datname'teledbdbnew'; pgterminatebackend t (1 row) teledb drop database teledbdbnew; DROP DATABASE

本文为您介绍如何删除模式。 您可执行如下操作删除模式。 teledb drop schema teledbschemaowner; DROP SCHEMA 当模式中存在对象时，则会删除失败，提示如下。 teledb create table teledbschemanew.test(id int); CREATE TABLE teledb drop schema teledbschemanew; ERROR: cannot drop schema teledbschemanew because other objects depend on it DETAIL: table teledbschemanew.test depends on schema teledbschemanew HINT: Use DROP ... CASCADE to drop the dependent objects too. 您可参考如下操作强制删除，会将模式中的对象也级联删除。 teledb drop schema teledbschemanew cascade; NOTICE: drop cascades to table teledbschemanew.test DROP SCHEMA

广州12345政府服务热线，业务的核心TeleDB服务器部署内网，敏感数据部署在这个核心TeleDB实例中，并涉及到130个部门，8千余个分类，4万余条知识点。该系统要求系统具备高安全性，目前存储了6000+加密表，同时要求通信链路加密，数据脱敏，访问白名单，TeleDB的多级安全策略在该业务系统有了完美的落地。该系统的核心系统结构如下：

TeleDB管控数据传输服务由管理模块、执行模块、稽核模块、核心配置集群、核心配置库组成，本文为您详细介绍具体的模块。 TeleDB管控数据传输服务由管理模块、执行模块、稽核模块、核心配置集群、核心配置库组成，具备广泛的兼容性，支持从多种数据源（如Oracle、MySQL、PostgreSQL等）迁移数据至TeleDB。这一功能为各类客户提供了一种简便、顺畅的迁移方式，能够顺利完成数据的迁移与整合。 管理模块 ：接受外部用户对系统的请求，对操作请求进行预处理和分发，并兼具进行任务管理、任务配置、监控数据查看、日志查看、工作节点调度等功能。 执行模块 ：具体负责执行数据迁移，接收管理模块的任务请求，依序执行迁移评估、结构迁移、全量迁移、增量迁移的具体工作流程。 稽核模块 ：负责在全量迁移完成后，对存量数据的正确性进行数据比对。包含对象级稽核、行级稽核、内容级稽核三个级别。对象级稽核比对源端和目标端数据库对象的结构是否一致，行级稽核比对源端表和目标端对应表的数据行数是否一致，内容级稽核比对源端表和目标端对应表的数据内容是否一致。 核心配置集群 ：负责增量任务位点管理、实时监控数据存储、任务状态存储和工作节点高可用。 核心配置库 ：负责存储和管理用户的任务信息以及部分元数据信息。

当提交工单显示系统错误时，您可以参考本文，查看问题现象、问题原因和解决方案。 问题现象 提交工单显示系统错误。 查看日志发现是sql插入有问题，instmanager的vip列插入失败。 原因分析 开通实例使用到了8个vip，给的varchar字符窜长度不够。 解决方案 执行如下命令增加vip列的varchar长度，将其修改为255。 use dcp desc instmanager alter table instmanager modify column vip varchar(255);

安装后校验 1. 检查容器状态：docker ps grep E 'dmsdas' 2. 检查启动日志：docker logs f 卸载服务 1. 查看容器ID，docker ps grep E 'dmsdas' 2. 停止容器：docker stop 3. 移除容器：docker rm 4. 查看镜像ID：docker images grep E 'dmsdas' 5. 移除镜像：docker rmi

参数 描述 示例 Policy Name Policy的名称。可以自定义。 testpolicy Hive Database 添加Hive中的数据库。 rangermaskdemo Hive Table 添加表。 usersensitiveinfo Hive Column 可添加列名。 idcard Select User 指定添加此策略的用户。 hdfs Access Types 选择授予的权限。 select Select Masking Option 选择脱敏方式。 hash

本章节主要介绍如何使用Ranger进行行级过滤。 行级过滤 Ranger支持对查询结果进行行级过滤。也就是说，可以根据预设条件动态限制用户可见的数据范围，让不同用户只能访问符合授权条件的数据子集。 操作步骤 1、在Ranger WebUI配置页面点击Hadoop SQL下的Hive页签，您可以对Hive数据进行脱敏处理。 2、单击上方的Row Level Filter页签。 3、单击右上角的Add New Policy。 4、在Create Policy页面，配置相关参数。 5、单击Add按钮添加policy。 Demo 1、简单 Row Filter 注册 row filter policy，HDFS 用户只能看到userid>3的数据。 Hive测试 Spark测试 2、复杂 Row Filter 设置表达式为email LIKE '%@gmail.com'只保留 gmail.com 后缀的数据。 Hive测试 Spark测试

本章节介绍如何登录Ranger的WebUI界面。 Ranger服务提供了集中式的权限管理框架，可以对HDFS、HBase、Hive等组件进行细粒度的权限访问控制，并且提供了WebUI方便Ranger管理员进行操作。 WebUI是用户操作的核心入口，主要用于统一管理各类组件（如HDFS、Hive、Spark、等）的权限策略、安全配置、审计日志等，无需在各个组件中单独配置权限。 操作步骤 1、获取Ranger admin用户密码（具体操作见账号密码类）。 2、访问Ranger WebUI（具体操作见通过弹性公网IP访问）。 3、在Ranger管理首页可查看当前Ranger已集成的各服务权限管理插件，用户可通过对应插件设置更细粒度的权限，具体主要操作页面功能描述参见下表。 入口 功能描述 Access Manager 查看当前Ranger已集成的各服务权限管理插件，用户可通过对应插件设置更细粒度的权限。 Audit 查看Ranger运行及权限管控相关审计日志信息。 Security Zone 配置安全区域，Ranger管理员可将各组件的资源切分为多个区域，由不同Ranger管理员为服务的指定资源设置安全策略，以便更好的管理。 Settings 查看Ranger相关权限设置信息，例如查看用户、用户组、Role等。

本章节主要介绍如何通过Ranger进行UDF管控。 在大数据平台中，UDF常用于扩展SQL的表达能力，例如字符串处理、脱敏转换、时间计算等。但如果缺少统一的权限管控，部分高风险UDF可能被滥用，进而带来数据泄露、越权访问或不符合规范的计算行为。因此，需要通过Ranger对UDF的访问进行统一治理，实现对函数使用范围的精细化控制。 操作步骤 1、登录Ranger的WebUI界面。 2、点击Hadoop SQL下的Hive页签，您可以对Hive UDF进行权限管控： 1）点击右上角的“Add New Policy”添加新策略。 2）Ranger Hive可以配置UDF权限，例如配置一个用户是否可以使用、创建UDF，具体配置见下图。 具体参数说明如下： 参数名称 描述 Policy Name 策略名称，可自定义，不能与本服务内其他策略名称重复。 Policy Label 为当前策略指定一个标签，您可以根据这些标签搜索报告和筛选策略。 database 将适用该策略的列Hive数据库名称。 udf 指定UDF的名称。 Description 策略描述信息。 Audit Logging 是否审计此策略。 Allow Conditions 策略允许条件，配置本策略内允许的权限及例外。 如需添加多条权限控制规则，可单击+按钮添加。 如需当前条件中的用户或用户组管理本条策略，可勾选“Delegate Admin”，这些用户将成为受委托的管理员。被委托的管理员可以更新、删除本策略，它还可以基于原始策略创建子策略。 Deny Conditions 策略拒绝条件，配置本策略内拒绝的权限及例外，配置方法与“Allow Conditions”类似。 3）如果该函数由 Hive 注册，且函数类型为 UDAF，则在 Ranger 配置 Policy 时需要特别注意 Database 字段的填写方式。此类函数的库名前需要补充前缀 @。例如，若函数的限定名称为 testdb.testfunction，则在 Policy 配置页面中，Database 应填写为 @testdb。

本章节主要介绍如何使用Ranger进行行级过滤。 行级过滤 Ranger支持对查询结果进行行级过滤。也就是说，可以根据预设条件动态限制用户可见的数据范围，让不同用户只能访问符合授权条件的数据子集。 操作步骤 1、在Ranger WebUI配置页面点击Hadoop SQL下的Hive页签，您可以对Hive数据进行脱敏处理。 2、单击上方的Row Level Filter页签。 3、单击右上角的Add New Policy。 4、在Create Policy页面，配置相关参数。 5、单击Add按钮添加policy。 Demo 1、简单 Row Filter 注册 row filter policy，HDFS 用户只能看到userid>3的数据。 Hive测试 Spark测试 2、复杂 Row Filter 设置表达式为email LIKE '%@gmail.com'只保留 gmail.com 后缀的数据。 Hive测试 Spark测试

本章节介绍如何登录Ranger的WebUI界面。 Ranger服务提供了集中式的权限管理框架，可以对HDFS、HBase、Hive等组件进行细粒度的权限访问控制，并且提供了WebUI方便Ranger管理员进行操作。 WebUI是用户操作的核心入口，主要用于统一管理各类组件（如HDFS、Hive、Spark、等）的权限策略、安全配置、审计日志等，无需在各个组件中单独配置权限。 操作步骤 1、获取Ranger admin用户密码（具体操作见账号密码类）。 2、访问Ranger WebUI（具体操作见通过弹性公网IP访问）。 3、在Ranger管理首页可查看当前Ranger已集成的各服务权限管理插件，用户可通过对应插件设置更细粒度的权限，具体主要操作页面功能描述参见下表。 入口 功能描述 Access Manager 查看当前Ranger已集成的各服务权限管理插件，用户可通过对应插件设置更细粒度的权限。 Audit 查看Ranger运行及权限管控相关审计日志信息。 Security Zone 配置安全区域，Ranger管理员可将各组件的资源切分为多个区域，由不同Ranger管理员为服务的指定资源设置安全策略，以便更好的管理。 Settings 查看Ranger相关权限设置信息，例如查看用户、用户组、Role等。

本章节主要介绍如何使用Ranger进行数据脱敏。 数据脱敏 Ranger支持对Hive查询结果进行数据脱敏。在执行SELECT查询并返回结果时，可以对敏感字段进行动态掩码处理，避免敏感信息以明文形式暴露。Ranger提供以下几种常见的脱敏方式： 1、Redact：全替换，将原始字符串整体替换为固定字符，通常用于彻底隐藏敏感信息。 2、Partial mask：部分替换，仅保留字符串中的部分内容，其余字符使用固定字符替换，例如只展示前4位或后4位。 3、Hash：哈希替换，将原始字符串转换为对应的哈希值，从而在隐藏原文的同时保留一定的可比对性。 4、Nullify：空值替换，将字段值直接替换为 NULL。 5、Date：日期脱敏，按照指定的日期格式输出脱敏结果，常见做法是仅保留年份。 6、Custom：自定义表达式，支持通过 SQL 表达式或 UDF 自定义脱敏逻辑，适用于更灵活的个性化场景。 操作步骤 1、在Ranger WebUI配置页面点击Hadoop SQL下的Hive页签，您可以对Hive数据进行脱敏处理。 2、单击上方的Masking页签。 3、单击右上角的Add New Policy。 4、在Create Policy页面，配置相关参数。 参数说明如下： 参数 描述 示例 Policy Name Policy的名称。可以自定义。 testpolicy Hive Database 添加Hive中的数据库。 rangermaskdemo Hive Table 添加表。 usersensitiveinfo Hive Column 可添加列名。 idcard Select User 指定添加此策略的用户。 hdfs Access Types 选择授予的权限。 select Select Masking Option 选择脱敏方式。 hash 5、单击Add按钮添加

本章节主要介绍 ALM12054 证书文件失效。 告警解释 系统每天二十三点检查当前系统中的证书文件是否失效（即当前集群中的证书文件是否过期，或者尚未生效）。如果证书文件失效，产生该告警。 当重新导入一个正常证书，并且状态不为失效状态，该告警恢复。 告警属性 告警ID 告警级别 是否自动清除 12054 重要 是 告警参数 参数名称 参数含义 来源 产生告警的集群或系统名称。 服务名 产生告警的服务名称。 角色名 产生告警的角色名称。 主机名 产生告警的主机名。 Trigger Condition 系统当前指标取值满足自定义的告警设置条件。 对系统的影响 提示用户证书文件已经失效，部分功能受限，无法正常使用。 可能原因 系统未导入证书（CA证书、HA根证书、HA用户证书、Gaussdb根证书或者Gaussdb用户证书等）、导入证书失败、证书文件失效。 处理步骤 查看告警原因 1.打开FusionInsight Manager页面，在实时告警列表中，单击此告警所在行的。 查看“附加信息”，获取告警附加信息。 告警附加信息中显示“CA Certificate”，以omm用户登录主OMS管理节点，执行步骤2。 告警附加信息中显示“HA root Certificate”，查看“定位信息”获取告警所在节点主机名，以omm用户登录该主机，执行步骤3。 告警附加信息中显示“HA server Certificate”，查看“定位信息”获取告警所在节点主机名，以omm用户登录该主机，执行步骤4。

告警ID 告警级别 是否自动清除 12041 重要 是

本章节主要介绍操作类问题中有关性能优化的问题。 MRS集群是否支持重装系统？是否支持切换操作系统？ MRS集群不支持重装系统，也不支持切换操作系统。 如何提高集群Core节点的资源使用率？ 1.进入 Yarn服务配置页面： −MRS 1.8.10及之前版本，登录MRS Manager页面，然后选择“服务管理 > Yarn > 服务配置”，单击“基础配置”下拉菜单，选择“全部配置”。 −MRS 1.8.10之后及2.x版本，单击集群名称，登录集群详情页面，选择“组件管理 > Yarn > 服务配置”，单击“基础配置”下拉菜单，选择“全部配置”。 说明 若集群详情页面没有“组件管理”页签，请先完成IAM用户同步（在集群详情页的“概览”页签，单击“IAM用户同步”右侧的“同步”进行IAM用户同步）。 −MRS 3.x及后续版本，登录FusionInsight Manager。然后选择“集群 > 待操作的集群名称 > 服务 > Yarn > 配置 > 全部配置”。 2.搜索并修改“yarn.nodemanager.resource.memorymb”的值，请根据集群的节点内存实际情况调大该值。 3.保存配置并重启受影响的服务或实例。 如何关闭防火墙服务？ 以root用户登录集群的各个节点。 1.检查防火墙服务是否启动。 例如，EulerOS环境下执行systemctl status firewalld.service命令。 2.关闭防火墙服务。

本章节主要介绍ALM14016 DataNode直接内存使用率超过阈值的告警。 告警解释 系统每30秒周期性检测HDFS服务直接内存使用状态，当检测到DataNode实例直接内存使用率超出阈值（最大内存的90%）时，产生该告警。 直接内存使用率小于阈值时，告警恢复。 告警属性 告警ID 告警级别 是否自动清除 14016 重要 是 告警参数 参数名称 参数含义 来源 产生告警的集群名称。 服务名 产生告警的服务名称。 角色名 产生告警的角色名称。 主机名 产生告警的主机名。 Trigger Condition 系统当前指标取值满足自定义的告警设置条件。 对系统的影响 DataNode可用直接内存不足，可能会造成内存溢出导致服务崩溃。 可能原因 该节点DataNode实例直接内存使用率过大，或配置的直接内存不合理，导致使用率超过阈值。 处理步骤 检查直接内存使用率 1.在FusionInsight Manager首页，选择“运维 > 告警 > 告警”，单击告警“ALM14016 DataNode直接内存使用率超过阈值”所在行的下拉菜单，在“定位信息”中查看告警上报的角色名并确定实例的IP地址。 2.在FusionInsight Manager首页，选择“集群 > 待操作集群的名称 > 服务 > HDFS > 实例 > DataNode（对应上报告警实例IP地址）”，单击图表区域右上角的下拉菜单，选择“定制 > 资源”，勾选“DataNode内存使用详情”。查看直接内存使用情况。 3.查看DataNode使用的直接内存是否已达到DataNode设定的最大直接内存的90%(默认阈值)。 是，执行步骤4。 否，执行步骤8。 4.在FusionInsight Manager首页，选择“集群 > 待操作集群的名称 > 服务 > HDFS > 配置 > 全部配置 > DataNode > 系统”。查看“GCOPTS”参数中是否存在“XX:MaxDirectMemorySize”。 是，执行步骤5。 否，执行步骤6。 5.调整“XX:MaxDirectMemorySize”大小。 在“GCOPTS”中查看 “Xmx”配置的大小，并判断节点内存是否够用。 说明 节点内存是否够用可根据实际环境进行判断，例如可使用以下方法： 以root用户登录告警上报的实例的IP地址，执行free g命令，查看“free”列的“Mem”值即为节点可用内存，如下示例中节点可用内存为4G。 total used free shared buff/cache available Mem: 112 48 4 10 58 46 ...... 如果节点可用内存大于或等于“Xmx”的值，则节点内存够用。如果节点可用内存小于“Xmx”的值，则节点内存不够用。 − 是，修改“XX:MaxDirectMemorySize”的配置值与“Xmx”配置值相同。 − 否，适量调大“XX:MaxDirectMemorySize”的大小，但取值不得超过节点可用内存。 保存配置，重启DataNode实例。 6.查看告警信息，是否存在告警“ALM14008 DataNode堆内存使用率超过阈值”。 是，参考“ALM14008 DataNode堆内存使用率超过阈值”进行处理。 否，执行步骤7。 7.观察界面告警是否清除。 是，处理完毕。 否，执行步骤8。

本章节主要介绍ALM12069 aos资源异常。 告警解释 HA每81秒周期性检测Manager的AOS资源。当HA连续2次检测到AOS资源异常时，产生该告警。 当HA检测到AOS资源正常后，告警恢复。 AOS资源为单主资源，一般资源异常会导致主备倒换，看到告警时，基本已经主备倒换，并在新主环境上启动新的ACS资源，告警恢复。该告警用于提示用户，Manager主备倒换的原因。 告警属性 告警ID 告警级别 是否自动清除 12069 重要 是 告警参数 参数名称 参数含义 来源 产生告警的集群或系统名称。 服务名 产生告警的服务名称。 角色名 产生告警的角色名称。 主机名 产生告警的主机名。 对系统的影响 Manager主备倒换。 AOS进程持续重启，可能引起无法登录FusionInsight Manager。 可能原因 AOS进程异常。 处理步骤 检查AOS进程是否异常 1.打开FusionInsight Manager页面，在告警列表中，单击此告警所在行的，查看该告警的主机名称。 2.以root用户登录该告警的主机地址。 3.执行命令 su omm ，执行 sh ${BIGDATAHOME}/omserver/OMS/workspace0/ha/module/hacom/script/statusha.sh ，查询当前HA管理的AOS资源状态是否正常（单机模式下面，AOS资源为normal状态；双机模式下，AOS资源在主节点为normal状态，在备节点为stopped状态。）。 是，执行步骤6。 否，执行步骤4。 4.执行命令 vi $BIGDATALOGHOME/omm/oms/ha/scriptlog/aos.log ，查看ha的AOS资源日志，是否有关键字“ERROR”，分析日志查看资源异常原因并修复。 5.等待五分钟，查看告警是否恢复。 是，操作结束。 否，执行步骤6。

收集故障信息 在FusionInsight Manager界面，选择“运维 > 日志 > 下载”。 6. 在“服务”中勾选待操作集群的“Spark2x”。 7. 单击右上角的设置日志收集的“开始时间”和“结束时间”分别为告警产生时间的前后10分钟，单击“下载”。 8. 请联系运维人员，并发送已收集的故障日志信息。 告警清除 此告警修复后，系统会自动清除此告警，无需手工清除。 参考信息 无。