SHOW-ROUTINE-LOAD
Name
SHOW ROUTINE LOAD
Description
该语句用于展示 Routine Load 作业运行状态
语法:
1. SHOW [ALL] ROUTINE LOAD [FOR jobName];
结果说明:
1. Id: 作业ID
2. Name: 作业名称
3. CreateTime: 作业创建时间
4. PauseTime: 最近一次作业暂停时间
5. EndTime: 作业结束时间
6. DbName: 对应数据库名称
7. TableName: 对应表名称 (多表的情况下由于是动态表,因此不显示具体表名,我们统一显示 multi-table )
8. IsMultiTbl: 是否为多表
9. State: 作业运行状态
10. DataSourceType: 数据源类型:KAFKA
11. CurrentTaskNum: 当前子任务数量
12. JobProperties: 作业配置详情
13. DataSourceProperties: 数据源配置详情
14. CustomProperties: 自定义配置
15. Statistic: 作业运行状态统计信息
16. Progress: 作业运行进度
17. Lag: 作业延迟状态
18. ReasonOfStateChanged: 作业状态变更的原因
19. ErrorLogUrls: 被过滤的质量不合格的数据的查看地址
20. OtherMsg: 其他错误信息
- State
1. 有以下5种State:
2. * NEED_SCHEDULE:作业等待被调度
3. * RUNNING:作业运行中
4. * PAUSED:作业被暂停
5. * STOPPED:作业已结束
6. * CANCELLED:作业已取消
- Progress
1. 对于Kafka数据源,显示每个分区当前已消费的offset。如 {"0":"2"} 表示Kafka分区0的消费进度为2。
- Lag
1. 对于Kafka数据源,显示每个分区的消费延迟。如{"0":10} 表示Kafka分区0的消费延迟为10。
Example
- 展示名称为 test1 的所有例行导入作业(包括已停止或取消的作业)。结果为一行或多行。
1. SHOW ALL ROUTINE LOAD FOR test1;
2. 展示名称为 test1 的当前正在运行的例行导入作业
1. SHOW ROUTINE LOAD FOR test1;
3. 显示 example_db 下,所有的例行导入作业(包括已停止或取消的作业)。结果为一行或多行。
1. use example_db;
2. SHOW ALL ROUTINE LOAD;
4. 显示 example_db 下,所有正在运行的例行导入作业
1. use example_db;
2. SHOW ROUTINE LOAD;
5. 显示 example_db 下,名称为 test1 的当前正在运行的例行导入作业
1. SHOW ROUTINE LOAD FOR example_db.test1;
6. 显示 example_db 下,名称为 test1 的所有例行导入作业(包括已停止或取消的作业)。结果为一行或多行。
1. SHOW ALL ROUTINE LOAD FOR example_db.test1;
Keywords
1. SHOW, ROUTINE, LOAD
