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

SHOW ROUTINE LOAD

Описание​

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

Синтаксис​

SHOW [ALL] ROUTINE LOAD [FOR <jobName>];

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

1. [ALL]

Необязательный параметр. Если он указан, отображаются все задания, включая остановленные и отменённые. В противном случае отображаются только выполняющиеся задания.

2. [FOR <jobName>]

Необязательный параметр. Задаёт имя задания для просмотра. Если не указан, отображаются все задания в текущей базе данных.

Поддерживаются следующие форматы:

  • <job_name>: отображает задание с указанным именем в текущей базе данных
  • <db_name>.<job_name>: отображает задание с указанным именем в указанной базе данных

Результаты​

Имя поляОписание
IdИдентификатор задания
NameИмя задания
CreateTimeВремя создания задания
PauseTimeВремя последней приостановки задания
EndTimeВремя завершения задания
DbNameИмя соответствующей базы данных
TableNameИмя соответствующей таблицы (для нескольких таблиц отображается 'multi-table')
IsMultiTableРаботает ли задание с несколькими таблицами
StateСостояние выполнения задания
DataSourceTypeТип источника данных: KAFKA
CurrentTaskNumТекущее количество подзадач
JobPropertiesПараметры конфигурации задания
DataSourcePropertiesПараметры конфигурации источника данных
CustomPropertiesПользовательские параметры конфигурации. Конфиденциальные свойства маскируются как ******, см. раздел «Маскирование конфиденциальных свойств» ниже
StatisticСтатистика выполнения задания
ProgressХод выполнения задания
LagСведения о задержке задания
ReasonOfStateChangedПричина изменения состояния задания
ErrorLogUrlsURL для просмотра отфильтрованных данных, не прошедших проверки качества
OtherMsgДругие сообщения об ошибках
UserПользователь, создавший задание
CommentКомментарий к заданию
ComputeGroupГруппа вычислений, в которой выполняется задание
FirstErrorMsgПервое сообщение об ошибке, возникшей при выполнении задания. Добавлено в версии 4.0.8 для ветки 4.0 и в версии 4.1.4 для ветки 4.1. Значение хранится в памяти FE и теряется при перезапуске FE; при сбросе статистики ошибок также очищается ErrorLogUrls

Маскирование конфиденциальных свойств​

Изменение поведения (4.0.8)

Начиная с версии 4.0.8, конфиденциальные свойства заданий Kafka Routine Load отображаются в виде ****** в CustomProperties вместо открытого текста. Вывод SHOW CREATE ROUTINE LOAD также маскируется.

Следующие свойства считаются конфиденциальными и маскируются:

Правило сопоставленияПример
Свойство с именем sasl.jaas.configsasl.jaas.config
Свойство с именем aws.access_keyaws.access_key
Свойство с именем ssl.keystore.key или ssl.key.pemssl.keystore.key
Имя оканчивается на .password, .secret, .secret_key или .secret.keyssl.keystore.password, sasl.oauthbearer.client.secret
Имя оканчивается на .session_key или .session.tokenaws.session.token
Имя оканчивается на .private.key, .private_key или .passphrase либо содержит .private.key.sasl.oauthbearer.assertion.private.key.pem

Маскирование влияет только на отображение значений; значения свойств, которые фактически использует задание, не меняются. Чтобы изменить эти свойства, задайте их заново с помощью ALTER ROUTINE LOAD; исходные значения нельзя получить из результата SHOW.

FirstErrorMsg и OtherMsg​

  • FirstErrorMsg: первая ошибка, возникшая при выполнении задания; помогает найти первопричину. Если задание выполняется долго, последующие ошибки часто оказываются следствием первой.
  • OtherMsg: последнее сообщение о другой ошибке; перезаписывается при последующих ошибках.
Примечание

Эти значения также можно получить запросом к information_schema.routine_load_job. Начиная с версии 4.0.8, запросы к этой таблице обслуживает главный FE, поэтому FIRST_ERROR_MSG и ERROR_LOG_URLS больше не пусты, когда запрос попадает на FE, который не является главным.

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

Для выполнения этой команды SQL пользователю необходима как минимум следующая привилегия:

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

Примечания​

  • Описание состояний:

    • NEED_SCHEDULE: задание ожидает планирования
    • RUNNING: задание выполняется
    • PAUSED: задание приостановлено
    • STOPPED: задание завершено
    • CANCELLED: задание отменено

  • Описание хода выполнения:

    • Для источника данных Kafka отображается смещение потребления для каждой партиции
    • Например, {"0":"2"} означает, что смещение потребления для партиции Kafka 0 равно 2

  • Описание задержки:

    • Для источника данных Kafka отображается задержка потребления для каждой партиции
    • Например, {"0":10} означает, что задержка потребления для партиции Kafka 0 равна 10

Примеры​

  • Показать все задания Routine Load (включая остановленные и отменённые) с именем test1

    SHOW ALL ROUTINE LOAD FOR test1;

  • Показать выполняющиеся задания Routine Load с именем test1

    SHOW ROUTINE LOAD FOR test1;

  • Показать все задания Routine Load (включая остановленные и отменённые) в example_db. Результат может содержать одну или несколько строк.

    use example_db;
    SHOW ALL ROUTINE LOAD;

  • Показать все выполняющиеся задания Routine Load в example_db

    use example_db;
    SHOW ROUTINE LOAD;

  • Показать выполняющееся задание Routine Load с именем test1 в example_db

    SHOW ROUTINE LOAD FOR example_db.test1;

  • Показать все задания Routine Load (включая остановленные и отменённые) с именем test1 в example_db. Результат может содержать одну или несколько строк.

    SHOW ALL ROUTINE LOAD FOR example_db.test1;
Report issue