跳到主要内容
版本: 最新版本-3.5

SHOW ROUTINE LOAD TASK

SHOW ROUTINE LOAD TASK 显示 Routine Load 作业中加载任务的执行信息。

注意

  • 您只能以对 StarRocks 表具有 INSERT 权限的用户身份管理在 StarRocks 表上运行的 Routine Load 作业。如果您没有 INSERT 权限，请按照 GRANT 中提供的说明，向用于连接到 StarRocks 集群的用户授予 INSERT 权限。

语法​

SHOW ROUTINE LOAD TASK
[  FROM <db_name>]
WHERE JobName = <job_name>
注意

您可以将 \G 选项添加到语句中（例如 SHOW ROUTINE LOAD TASK WHERE JobName = <job_name>\G），以垂直显示返回结果，而不是通常的水平表格格式。

参数​

参数必需描述
db_name否Routine Load 作业所属的数据库的名称。
JobName是Routine Load 作业的名称。

输出​

参数描述
TaskId加载任务的全局唯一 ID，由 StarRocks 自动生成。
TxnId加载任务所属事务的 ID。
TxnStatus加载任务所属事务的状态。UNKNOWN 表示事务尚未启动，可能是因为加载任务尚未调度或执行。
JobId加载作业的 ID。
CreateTime创建加载任务的日期和时间。
LastScheduledTime上次调度加载任务的日期和时间。
ExecuteStartTime执行加载任务的日期和时间。
Timeout加载任务的超时时间段，由 FE 参数 routine_load_task_timeout_second 和 job_properties Routine Load 作业中的 task_timeout_second 参数控制。
BeId执行加载任务的 BE 的 ID。
DataSourceProperties加载任务在主题分区中消费消息的进度（以偏移量衡量）。
Message为加载任务返回的信息，包括任务错误信息。

示例​

查看 Routine Load 作业 example_tbl_ordertest 中的所有加载任务。

MySQL [example_db]> SHOW ROUTINE LOAD TASK WHERE JobName = "example_tbl_ordertest";  
+--------------------------------------+-------+-----------+-------+---------------------+---------------------+------------------+---------+------+------------------------------------+-----------------------------------------------------------------------------+
| TaskId                               | TxnId | TxnStatus | JobId | CreateTime          | LastScheduledTime   | ExecuteStartTime | Timeout | BeId | DataSourceProperties               | Message                                                                     |
+--------------------------------------+-------+-----------+-------+---------------------+---------------------+------------------+---------+------+------------------------------------+-----------------------------------------------------------------------------+
| abde6998-c19a-43d6-b48c-6ca7e14144a3 | -1    | UNKNOWN   | 10208 | 2023-12-22 12:46:10 | 2023-12-22 12:47:00 | NULL             | 60      | -1   | Progress:{"0":6},LatestOffset:null | there is no new data in kafka/pulsar, wait for 10 seconds to schedule again |
+--------------------------------------+-------+-----------+-------+---------------------+---------------------+------------------+---------+------+------------------------------------+-----------------------------------------------------------------------------+
1 row in set (0.00 sec)