Перейти к основному содержимому

SHOW ROUTINE LOAD TASK

SHOW ROUTINE LOAD TASK отображает информацию о выполнении задач загрузки в рамках задания Routine Load.

примечание
  • Вы можете управлять заданиями Routine Load, которые выполняются на таблицах Selena, только как пользователь, имеющий привилегию INSERT на эти таблицы Selena. Если у вас нет привилегии INSERT, следуйте инструкциям, предоставленным в GRANT, чтобы предоставить привилегию INSERT пользователю, которого вы используете для подключения к вашему кластеру Selena.

Синтаксис

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 задачи загрузки, автоматически генерируемый Selena.
TxnIdID транзакции, к которой принадлежит задача загрузки.
TxnStatusСтатус транзакции, к которой принадлежит задача загрузки. UNKNOWN указывает, что транзакция еще не запущена, возможно, потому что задача загрузки не отправлена или не выполнена.
JobIdID задания загрузки.
CreateTimeДата и время создания задачи загрузки.
LastScheduledTimeДата и время последнего планирования задачи загрузки.
ExecuteStartTimeДата и время выполнения задачи загрузки.
TimeoutПериод тайм-аута для задачи загрузки, контролируемый параметром FE routine_load_task_timeout_second и параметром task_timeout_second в job_properties задания Routine Load.
BeIdID BE, который выполняет задачу загрузки.
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)