SHOW ROUTINE LOAD

description

1. 该语句用于展示 Routine Load 作业运行状态
2. 语法:
3. SHOW [ALL] ROUTINE LOAD [FOR jobName];

5. 结果说明:

7. Id: 作业ID
8. Name: 作业名称
9. CreateTime: 作业创建时间
10. PauseTime: 最近一次作业暂停时间
11. EndTime: 作业结束时间
12. DbName: 对应数据库名称
13. TableName: 对应表名称
14. State: 作业运行状态
15. DataSourceType: 数据源类型:KAFKA
16. CurrentTaskNum: 当前子任务数量
17. JobProperties: 作业配置详情

DataSourceProperties: 数据源配置详情 CustomProperties: 自定义配置 Statistic: 作业运行状态统计信息 Progress: 作业运行进度 Lag: 作业延迟状态 ReasonOfStateChanged: 作业状态变更的原因 ErrorLogUrls: 被过滤的质量不合格的数据的查看地址 OtherMsg: 其他错误信息

1. * State

3. 有以下4种State:

5. * NEED_SCHEDULE:作业等待被调度
6. * RUNNING:作业运行中
7. * PAUSED:作业被暂停
8. * STOPPED:作业已结束
9. * CANCELLED:作业已取消

11. * Progress

13. 对于Kafka数据源,显示每个分区当前已消费的offset。如 {"0":"2"} 表示Kafka分区0的消费进度为2。

15. * Lag

17. 对于Kafka数据源,显示每个分区的消费延迟。如{"0":10} 表示Kafka分区0的消费延迟为10。

example

  1. 展示名称为 test1 的所有例行导入作业(包括已停止或取消的作业)。结果为一行或多行。

SHOW ALL ROUTINE LOAD FOR test1; 2. 展示名称为 test1 的当前正在运行的例行导入作业

SHOW ROUTINE LOAD FOR test1; 3. 显示 example_db 下,所有的例行导入作业(包括已停止或取消的作业)。结果为一行或多行。

use example_db; SHOW ALL ROUTINE LOAD; 4. 显示 example_db 下,所有正在运行的例行导入作业

use example_db; SHOW ROUTINE LOAD; 5. 显示 example_db 下,名称为 test1 的当前正在运行的例行导入作业

SHOW ROUTINE LOAD FOR example_db.test1; 6. 显示 example_db 下,名称为 test1 的所有例行导入作业(包括已停止或取消的作业)。结果为一行或多行。

SHOW ALL ROUTINE LOAD FOR example_db.test1;

keyword

1. SHOW,ROUTINE,LOAD