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

  1. 展示名称为 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

Best Practice