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

SHOW ROUTINE LOAD TASK

Описание​

Этот синтаксис используется для просмотра выполняющихся в данный момент подзадач указанного задания Routine Load.

Синтаксис​

SHOW ROUTINE LOAD TASK WHERE JobName = <job_name>;

SHOW ROUTINE LOAD TASK FOR [<db>.]<job_name>;

Обязательные параметры​

1. <job_name>

Имя задания Routine Load, информацию о котором нужно просмотреть.

Необязательные параметры​

1. <db>

База данных, в которой находится задание Routine Load. Если параметр не указан, задание Routine Load ищется в текущей базе данных.

Возвращаемые результаты​

Возвращаемые результаты содержат следующие поля:

Имя поляОписание
TaskIdУникальный идентификатор подзадачи
TxnIdИдентификатор транзакции загрузки, соответствующей подзадаче
TxnStatusСтатус транзакции загрузки подзадачи. Null означает, что подзадача ещё не запланирована к выполнению
JobIdИдентификатор задания, которому принадлежит подзадача
CreateTimeВремя создания подзадачи
ExecuteStartTimeВремя, когда подзадача была запланирована к выполнению; обычно позже времени создания
TimeoutТайм-аут подзадачи, обычно равный удвоенному значению max_batch_interval, заданному в задании
BeIdИдентификатор узла BE, выполняющего эту подзадачу
DataSourcePropertiesНачальное смещение раздела Kafka, из которого подзадача готовится читать данные. Это строка в формате JSON. Ключом служит идентификатор раздела, а значением служит начальное смещение для чтения

Требования к правам доступа​

Пользователи, выполняющие эту команду SQL, должны иметь как минимум следующие привилегии:

ПривилегияОбъектПримечания
LOAD_PRIVТаблицаДля SHOW ROUTINE LOAD TASK требуется привилегия LOAD для таблицы

Примечания​

  • Значение null в TxnStatus не указывает на ошибку задачи: оно может означать, что задача ещё не запланирована к выполнению
  • Информацию о смещениях в DataSourceProperties можно использовать для отслеживания хода чтения данных
  • По истечении Timeout задача автоматически завершается независимо от того, завершено ли чтение данных

Примеры​

  • Показать информацию о подзадачах задания Routine Load с именем test1.

    SHOW ROUTINE LOAD TASK WHERE JobName = "test1";
  • Показать информацию о подзадачах задания Routine Load test1 в текущей базе данных.

    SHOW ROUTINE LOAD TASK FOR test1;
  • Показать информацию о подзадачах задания Routine Load test1 в базе данных example_db.

    SHOW ROUTINE LOAD TASK FOR example_db.test1;