更新日期：2024年09月11日
1.
使用智能索引且最有效的方法是字段与常量表达式直接操作的形式：
(rownumtag>=100*10);
改成
(rownumtag+1>=100*10+1);
就无法使用智能索引。
2.
其次一边是字段，另一边是常量表达式（常量当然也可以），常量表达式无
论多么复杂都没有问题，因为它只需要计算一遍。
表达式与常量进行比较的条件不能用智能索引。
GBase 8a MPP Cluster 产品手册
5 数据库管理指南
文档版本953（2022-09-15）
南大通用数据技术股份有限公司
1304
如：
SELECT ... FROM ... WHERE ceil(rownumtag / ceil(TO_NUMBER('100')))
='10' ;
改为：
SELECT ... FROM ... WHERE rownumtag>100*9 AND
rownumtag<=100*10;
功能说明
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 消息出错以及详细的错
误原因、目标表不存在、目标表列定义错误（列名、
列数量、列顺序）、在集群层处理数据同步的时候发
生错误、发给单机执行单机报错、提交错误。
[root@PRIMARY ~]# cd /home/gbasedbt/
[root@PRIMARY gbasedbt]# su gbasedbt
[gbasedbt@PRIMARY ~]$ vim profile.gbaseserver
内容如下：
export GBASEDBTSERVER=gbaseserver
export GBASEDBTDIR=/opt/GBASE/gbase
export GBASEDBTSQLHOSTS=/opt/GBASE/gbase/etc/sqlhosts.gbaseserver
export ONCONFIG=onconfig.gbaseserver
export PATH=/opt/GBASE/gbase/bin:$PATH
export DB_LOCALE=zh_CN.GB18030-2000
export CLIENT_LOCALE=zh_CN.GB18030-2000
export GL_USEGLU=1
为了gbasedbt用户在登录后自动应用这些环境变量，可以修改.bash_profile文件，在文
件后添加如下内容：
source /home/gbasedbt/profile.gbaseserver