gbase数据、南大通用产品文档：GBase8a状态查询

功能说明

GBase 8a MPP Cluster 产品手册
5 数据库管理指南
文档版本953（2022-04-10）
南大通用数据技术股份有限公司
1280
查询所有已启动的consumer task 的同步状态。
语法格式
查询所有已启动的transaction topic consumer task 的同步状态。
SELECT * FROM information_schema.kafka_consumer_status;
查询所有已启动的loader topic consumer task 的同步状态。
SELECT * FROM information_schema.kafka_loader_consumer_status;
表5- 164 参数说明
字段名称
含义说明
Consumer
consumer name。
IP
consumer task 运行在哪个节点（IP 地址）
Topic
kafka topic name。
Status
Consumer task 当前状态
Start 正在执行
Stop 已停止
Waiting start 正在启动中
Min_offset
当前kafka 队列里的最小offset，如果成功连接到了
kafka server，这个字段是实际值，否则是0。
Max_offset
当前kafka 队列里的最大offset，如果成功连接到了
kafka server，这个字段是实际值，否则是0。
Cur_offset
GBase 8a MPP Cluster 目前正在取得的消息的offset。
Process_offset
GBase 8a MPP Cluster 正在执行同步的消息的offset。
Partition_offsets
加载成功的最后一次落地数据所在的offset，包含各
个partition 的offset。
Commit_offset
GBase 8a MPP Cluster 最后一次执行commit 操作时，
对应的消息的offset。
Exception
最后一次出现错误时的错误描述信息，
异常包括：
连
不上kafka server、解析json 消息出错以及详细的错
误原因、目标表不存在、目标表列定义错误（列名、
列数量、列顺序）、在集群层处理数据同步的时候发
生错误、发给单机执行单机报错、提交错误。

示例1
两个操作数都是整型。
gbase> SELECT 5 DIV 2 FROM t;
+---------+
| 5 DIV 2 |
+---------+
| 2 |
+---------+
1 row in set
说明
函数失败时，不同引擎表现不同，例如：
4 DIV 0 在8a 上返回NULL，在hive 引擎报错；
4 DIV -2.567 在8a 上会将返回-1，在hive 引擎报错。

参数说明：设置用于处理告警内容的告警组件的位置。
取值范围：字符串。修改后需要重启cm_server 才能生效。参数修改请参考表2 进行设
置。

若前置脚本gs_preinstall 中的–alarm-type 参数设置为5 时，
表示未对接第三方组件，
告警写入system_alarm 日志，此时GUC 参数alarm_component 的取值为：
/opt/huawei/snas/bin/snas_cm_cmd。

若前置脚本gs_preinstall 中的–alarm-type 参数设置为1 时，表示对接第三方组件，
此时GUC 参数alarm_component 的值为第三方组件的可执行程序的绝对路径。
默认值：/opt/huawei/snas/bin/snas_cm_cmd