Перейти к основному содержимому
Версия: 2.0.x

SHOW LOAD

SHOW LOAD отображает информацию обо всех загрузочных заданиях или заданных загрузочных заданиях в базе данных. Эта команда может отображать только загрузочные задания, созданные с помощью Broker Load, INSERT и SPARK_LOAD. Вы также можете просматривать информацию о загрузочных заданиях с помощью команды curl. Начиная с версии 3.1, мы рекомендуем использовать команду SELECT для запроса результатов заданий Broker Load или Insert из таблицы loads в базе данных information_schema. Для получения дополнительной информации см. Loading.

Помимо вышеупомянутых методов загрузки, Selena поддерживает использование Stream Load и Routine Load для загрузки данных. Stream Load является синхронной операцией и будет напрямую возвращать информацию о заданиях Stream Load. Routine Load является асинхронной операцией, где вы можете использовать команду SHOW ROUTINE LOAD для отображения информации о заданиях Routine Load.

Синтаксис

SHOW LOAD [ FROM db_name ]
[
WHERE [ LABEL { = "label_name" | LIKE "label_matcher" } ]
[ [AND] STATE = { "PENDING" | "ETL" | "LOADING" | "FINISHED" | "CANCELLED" } ]
]
[ ORDER BY field_name [ ASC | DESC ] ]
[ LIMIT { [offset, ] limit | limit OFFSET offset } ]

Примечание

Вы можете добавить опцию \G к команде (например, SHOW LOAD WHERE LABEL = "label1"\G;), чтобы отображать вывод вертикально, а не в обычном горизонтальном табличном формате. Для получения дополнительной информации см. Пример 1.

Параметры

ПараметрОбязательныйОписание
db_nameНетИмя базы данных. Если этот параметр не указан, по умолчанию используется текущая база данных.
LABEL = "label_name"НетМетки загрузочных заданий.
LABEL LIKE "label_matcher"НетЕсли этот параметр указан, возвращается информация о загрузочных заданиях, метки которых содержат label_matcher.
ANDНет
  • Если вы указываете только одно условие фильтра в предложении WHERE, не указывайте это ключевое слово. Пример: WHERE STATE = "PENDING".
  • Если вы указываете два или три условия фильтра в предложении WHERE, вы должны указать это ключевое слово. Пример: WHERE LABEL = "label_name" AND STATE = "PENDING".
STATEНетСостояния загрузочных заданий. Состояния различаются в зависимости от методов загрузки.
  • Broker Load
    • PENDING: Загрузочное задание создано.
    • QUEUEING: Загрузочное задание находится в очереди в ожидании планирования.
    • LOADING: Загрузочное задание выполняется.
    • PREPARED: Транзакция зафиксирована.
    • FINISHED: Загрузочное задание выполнено успешно.
    • CANCELLED: Загрузочное задание завершилось с ошибкой.
  • Spark Load
    • PENDING: Ваш кластер Selena готовит конфигурации, связанные с ETL, а затем отправляет задание ETL в ваш кластер Apache Spark™.
    • ETL: Ваш кластер Spark выполняет задание ETL, а затем записывает данные в соответствующий кластер HDFS.
    • LOADING: Данные из кластера HDFS загружаются в ваш кластер Selena, что означает, что загрузочное задание выполняется.
    • PREPARED: Транзакция зафиксирована.
    • FINISHED: Загрузочное задание выполнено успешно.
    • CANCELLED: Загрузочное задание завершилось с ошибкой.
  • INSERT
    • FINISHED: Загрузочное задание выполнено успешно.
    • CANCELLED: Загрузочное задание завершилось с ошибкой.
Если параметр STATE не указан, по умолчанию возвращается информация о загрузочных заданиях во всех состояниях. Если параметр STATE указан, возвращается только информация о загрузочных заданиях в заданном состоянии. Например, STATE = "PENDING" возвращает информацию о загрузочных заданиях в состоянии PENDING.
ORDER BY field_name [ASC | DESC]НетЕсли этот параметр указан, вывод сортируется по возрастанию или убыванию на основе поля. Поддерживаются следующие поля: JobId, Label, State, Progress, Type, EtlInfo, TaskInfo, ErrorMsg, CreateTime, EtlStartTime, EtlFinishTime, LoadStartTime, LoadFinishTime, URL и JobDetails.
  • Для сортировки вывода по возрастанию укажите ORDER BY field_name ASC.
  • Для сортировки вывода по убыванию укажите ORDER BY field_name DESC.
Если вы не указываете поле и порядок сортировки, вывод по умолчанию сортируется по возрастанию JobId.
LIMIT limitНетКоличество загрузочных заданий, которые разрешено отображать. Если этот параметр не указан, отображается информация обо всех загрузочных заданиях, соответствующих условиям фильтра. Если этот параметр указан, например, LIMIT 10, возвращается только информация о 10 загрузочных заданиях, соответствующих условиям фильтра.
OFFSET offsetНетПараметр offset определяет количество загрузочных заданий, которые нужно пропустить. Например, OFFSET 5 пропускает первые пять загрузочных заданий и возвращает остальные. Значение параметра offset по умолчанию равно 0.

Вывод

+-------+-------+-------+----------+------+---------+----------+----------+------------+--------------+---------------+---------------+----------------+-----+------------+
| JobId | Label | State | Progress | Type | Priority | EtlInfo | TaskInfo | ErrorMsg | CreateTime | EtlStartTime | EtlFinishTime | LoadStartTime | LoadFinishTime | URL | JobDetails |
+-------+-------+-------+----------+------+---------+----------+----------+------------+--------------+---------------+---------------+----------------+-----+------------+

Вывод этой команды различается в зависимости от методов загрузки.

ПолеBroker LoadSpark LoadINSERT
JobIdУникальный ID, присвоенный Selena для идентификации загрузочного задания в вашем кластере Selena.Поле имеет то же значение в задании Spark Load, что и в задании Broker Load.Поле имеет то же значение в задании INSERT, что и в задании Broker Load.
LabelМетка загрузочного задания. Метка загрузочного задания уникальна в пределах базы данных, но может дублироваться в разных базах данных.Поле имеет то же значение в задании Spark Load, что и в задании Broker Load.Поле имеет то же значение в задании INSERT, что и в задании Broker Load.
StateСостояние загрузочного задания.
  • PENDING: Загрузочное задание создано.
  • QUEUEING: Загрузочное задание находится в очереди в ожидании планирования.
  • LOADING: Загрузочное задание выполняется.
  • PREPARED: Транзакция зафиксирована.
  • FINISHED: Загрузочное задание выполнено успешно.
  • CANCELLED: Загрузочное задание завершилось с ошибкой.
Состояние загрузочного задания.
  • PENDING: Ваш кластер Selena готовит конфигурации, связанные с ETL, а затем отправляет задание ETL в ваш кластер Spark.
  • ETL: Ваш кластер Spark выполняет задание ETL, а затем записывает данные в соответствующий кластер HDFS.
  • LOADING: Данные из кластера HDFS загружаются в ваш кластер Selena, что означает, что загрузочное задание выполняется.
  • PREPARED: Транзакция зафиксирована.
  • FINISHED: Загрузочное задание выполнено успешно.
  • CANCELLED: Загрузочное задание завершилось с ошибкой.
Состояние загрузочного задания.
  • FINISHED: Загрузочное задание выполнено успешно.
  • CANCELLED: Загрузочное задание завершилось с ошибкой.
ProgressСтадия загрузочного задания. Задание Broker Load имеет только стадию LOAD, которая варьируется от 0% до 100% для описания прогресса стадии. Когда загрузочное задание входит в стадию LOAD, для параметра State возвращается LOADING. Задание Broker Load не имеет стадии ETL. Параметр ETL действителен только для задания Spark Load.
Примечание
  • Формула для расчета прогресса стадии LOAD: Количество таблиц Selena, которые завершили загрузку данных/Количество таблиц Selena, в которые вы планируете загрузить данные * 100%.
  • Когда все данные загружены в Selena, для параметра LOAD возвращается 99%. Затем загруженные данные начинают вступать в силу в Selena. После того как данные вступят в силу, для параметра LOAD возвращается 100%.
  • Прогресс стадии LOAD не является линейным. Поэтому значение параметра LOAD может не изменяться в течение определенного периода времени, даже если загрузка данных все еще продолжается.
Стадия загрузочного задания. Задание Spark Load имеет две стадии:
  • ETL: варьируется от 0% до 100% для описания прогресса стадии ETL.
  • LOAD: варьируется от 0% до 100% для описания прогресса стадии Load.
Когда загрузочное задание входит в стадию ETL, для параметра State возвращается ETL. Когда загрузочное задание переходит в стадию LOAD, для параметра State возвращается LOADING.
Примечание такое же, как для Broker Load.
Стадия загрузочного задания. Задание INSERT имеет только стадию LOAD, которая варьируется от 0% до 100% для описания прогресса стадии. Когда загрузочное задание входит в стадию LOAD, для параметра State возвращается LOADING. Задание INSERT не имеет стадии ETL. Параметр ETL действителен только для задания Spark Load.
Примечание такое же, как для Broker Load.
TypeМетод загрузочного задания. Значение этого параметра по умолчанию равно BROKER.Метод загрузочного задания. Значение этого параметра по умолчанию равно SPARK.Метод загрузочного задания. Значение этого параметра по умолчанию равно INSERT.
PriorityПриоритет загрузочного задания. Допустимые значения: LOWEST, LOW, NORMAL, HIGH и HIGHEST.--
EtlInfoМетрики, связанные с ETL.
  • unselected.rows: Количество строк, отфильтрованных предложением WHERE.
  • dpp.abnorm.ALL: Количество строк, отфильтрованных из-за проблем с качеством данных, которое относится к несоответствиям между исходными таблицами и таблицами Selena в, например, типе данных и количестве столбцов.
  • dpp.norm.ALL: Количество строк, загруженных в ваш кластер Selena.
Сумма вышеуказанных метрик представляет собой общее количество строк необработанных данных. Вы можете использовать следующую формулу для расчета того, превышает ли процент некачественных данных значение параметра max-filter-ratio:dpp.abnorm.ALL/(unselected.rows + dpp.abnorm.ALL + dpp.norm.ALL).
Поле имеет то же значение в задании Spark Load, что и в задании Broker Load.Метрики, связанные с ETL. Задание INSERT не имеет стадии ETL. Поэтому возвращается NULL.
TaskInfoПараметры, которые указываются при создании загрузочного задания.
  • resource: Этот параметр действителен только в задании Spark Load.
  • timeout: Период времени, в течение которого загрузочному заданию разрешено выполняться. Единица измерения: секунды.
  • max-filter-ratio: Наибольший процент строк, отфильтрованных из-за проблем с качеством данных.
Для получения дополнительной информации см. BROKER LOAD.
Параметры, которые указываются при создании загрузочного задания.
  • resource: Имя ресурса.
  • timeout: Период времени, в течение которого загрузочному заданию разрешено выполняться. Единица измерения: секунды.
  • max-filter-ratio: Наибольший процент строк, отфильтрованных из-за проблем с качеством данных.
Для получения дополнительной информации см. SPARK LOAD.
Параметры, которые указываются при создании загрузочного задания.
  • resource: Этот параметр действителен только в задании Spark Load.
  • timeout: Период времени, в течение которого загрузочному заданию разрешено выполняться. Единица измерения: секунды.
  • max-filter-ratio: Наибольший процент строк, отфильтрованных из-за проблем с качеством данных.
Для получения дополнительной информации см. INSERT.
ErrorMsgСообщение об ошибке, возвращаемое при сбое загрузочного задания. Когда состояние загрузочного задания PENDING, LOADING или FINISHED, для поля ErrorMsg возвращается NULL. Когда состояние загрузочного задания CANCELLED, значение, возвращаемое для поля ErrorMsg, состоит из двух частей: type и msg.
  • Часть type может быть любым из следующих значений:
    • USER_CANCEL: Загрузочное задание было отменено вручную.
    • ETL_SUBMIT_FAIL: Не удалось отправить загрузочное задание.
    • ETL-QUALITY-UNSATISFIED: Загрузочное задание завершилось с ошибкой, поскольку процент некачественных данных превышает значение параметра max-filter-ratio.
    • LOAD-RUN-FAIL: Загрузочное задание завершилось с ошибкой на стадии LOAD.
    • TIMEOUT: Загрузочное задание не удалось завершить в течение указанного периода времени ожидания.
    • UNKNOWN: Загрузочное задание завершилось с ошибкой из-за неизвестной ошибки.
  • Часть msg содержит подробную причину сбоя загрузки.
Сообщение об ошибке, возвращаемое при сбое загрузочного задания. Когда состояние загрузочного задания PENDING, LOADING или FINISHED, для поля ErrorMsg возвращается NULL. Когда состояние загрузочного задания CANCELLED, значение, возвращаемое для поля ErrorMsg, состоит из двух частей: type и msg.
  • Часть type может быть любым из следующих значений:
    • USER_CANCEL: Загрузочное задание было отменено вручную.
    • ETL_SUBMIT_FAIL: Selena не удалось отправить задание ETL в Spark.
    • ETL-RUN-FAIL: Spark не удалось выполнить задание ETL.
    • ETL-QUALITY-UNSATISFIED: Загрузочное задание завершилось с ошибкой, поскольку процент некачественных данных превышает значение параметра max-filter-ratio.
    • LOAD-RUN-FAIL: Загрузочное задание завершилось с ошибкой на стадии LOAD.
    • TIMEOUT: Загрузочное задание не удалось завершить в течение указанного периода времени ожидания.
    • UNKNOWN: Загрузочное задание завершилось с ошибкой из-за неизвестной ошибки.
  • Часть msg содержит подробную причину сбоя загрузки.
Сообщение об ошибке, возвращаемое при сбое загрузочного задания. Когда состояние загрузочного задания FINISHED, для поля ErrorMsg возвращается NULL. Когда состояние загрузочного задания CANCELLED, значение, возвращаемое для поля ErrorMsg, состоит из двух частей: type и msg.
  • Часть type может быть любым из следующих значений:
    • USER_CANCEL: Загрузочное задание было отменено вручную.
    • ETL_SUBMIT_FAIL: Не удалось отправить загрузочное задание.
    • ETL_RUN_FAIL: Не удалось запустить загрузочное задание.
    • ETL_QUALITY_UNSATISFIED: Загрузочное задание завершилось с ошибкой из-за проблем с качеством необработанных данных.
    • LOAD-RUN-FAIL: Загрузочное задание завершилось с ошибкой на стадии LOAD.
    • TIMEOUT: Загрузочное задание не удалось завершить в течение указанного периода времени ожидания.
    • UNKNOWN: Загрузочное задание завершилось с ошибкой из-за неизвестной ошибки.
    • TXN_UNKNOWN: Загрузочное задание завершилось с ошибкой, поскольку состояние транзакции загрузочного задания неизвестно.
  • Часть msg содержит подробную причину сбоя загрузки.
CreateTimeВремя, когда было создано загрузочное задание.Поле имеет то же значение в задании Spark Load, что и в задании Broker Load.Поле имеет то же значение в задании INSERT, что и в задании Broker Load.
EtlStartTimeЗадание Broker Load не имеет стадии ETL. Поэтому значение этого поля совпадает со значением поля LoadStartTime.Время начала стадии ETL.Задание INSERT не имеет стадии ETL. Поэтому значение этого поля совпадает со значением поля LoadStartTime.
EtlFinishTimeЗадание Broker Load не имеет стадии ETL. Поэтому значение этого поля совпадает со значением поля LoadStartTime.Время завершения стадии ETL.Задание INSERT не имеет стадии ETL. Поэтому значение этого поля совпадает со значением поля LoadStartTime.
LoadStartTimeВремя начала стадии LOAD.Поле имеет то же значение в задании Spark Load, что и в задании Broker Load.Поле имеет то же значение в задании INSERT, что и в задании Broker Load.
LoadFinishTimeВремя завершения загрузочного задания.Поле имеет то же значение в задании Spark Load, что и в задании Broker Load.Поле имеет то же значение в задании INSERT, что и в задании Broker Load.
URLURL-адрес, который используется для доступа к некачественным данным, обнаруженным в загрузочном задании. Вы можете использовать команду curl или wget для доступа к URL-адресу и получения некачественных данных. Если некачественные данные не обнаружены, возвращается NULL.Поле имеет то же значение в задании Spark Load, что и в задании Broker Load.Поле имеет то же значение в задании INSERT, что и в задании Broker Load.
JobDetailsДругая информация, связанная с загрузочным заданием.
  • Unfinished backends: ID BE, который не завершил загрузку данных.
  • ScannedRows: Общее количество строк, загруженных в Selena, и количество строк, которые были отфильтрованы.
  • TaskNumber: Загрузочное задание может быть разделено на одну или несколько задач, которые выполняются параллельно. Это поле указывает количество загрузочных задач.
  • All backends: ID BE, который выполняет загрузку данных.
  • FileNumber: Количество файлов исходных данных.
  • FileSize: Объем данных файлов исходных данных. Единица измерения: байты.
Поле имеет то же значение в задании Spark Load, что и в задании Broker Load.Поле имеет то же значение в задании INSERT, что и в задании Broker Load.

Примечания по использованию

  • Информация, возвращаемая командой SHOW LOAD, действительна в течение 3 дней с момента LoadFinishTime загрузочного задания. По истечении 3 дней информация не может быть отображена. Вы можете использовать параметр label_keep_max_second для изменения периода действия по умолчанию.

    ADMIN SET FRONTEND CONFIG ("label_keep_max_second" = "value");
  • Если значение поля LoadStartTime долгое время остается N/A, это означает, что загрузочные задания сильно накапливаются. Мы рекомендуем сократить частоту создания загрузочных заданий.

  • Общий период времени, затраченный на загрузочное задание = LoadFinishTime - CreateTime.

  • Общий период времени, затраченный загрузочным заданием на стадии LOAD = LoadFinishTime - LoadStartTime.

Примеры

Пример 1: Вертикально отобразить все загрузочные задания в текущей базе данных.

SHOW LOAD\G
*************************** 1. row ***************************
JobId: 976331
Label: duplicate_table_with_null
State: FINISHED
Progress: ETL:100%; LOAD:100%
Type: BROKER
Priority: NORMAL
EtlInfo: unselected.rows=0; dpp.abnorm.ALL=0; dpp.norm.ALL=65546
TaskInfo: resource:N/A; timeout(s):300; max_filter_ratio:0.0
ErrorMsg: NULL
CreateTime: 2022-10-17 19:35:00
EtlStartTime: 2022-10-17 19:35:04
EtlFinishTime: 2022-10-17 19:35:04
LoadStartTime: 2022-10-17 19:35:04
LoadFinishTime: 2022-10-17 19:35:06
URL: NULL
JobDetails: {"Unfinished backends":{"b90a703c-6e5a-4fcb-a8e1-94eca5be0b8f":[]},"ScannedRows":65546,"TaskNumber":1,"All backends":{"b90a703c-6e5a-4fcb-a8e1-94eca5be0b8f":[10004]},"FileNumber":1,"FileSize":548622}

Пример 2: Отобразить два загрузочных задания, метки которых содержат строку null в текущей базе данных.

SHOW LOAD
WHERE LABEL LIKE "null"
LIMIT 2;

+-------+---------------------------+----------+---------------------+--------+---------------------------------------------------------+---------------------------------------------------------------------------------------------------------+----------+---------------------+---------------------+---------------------+---------------------+---------------------+--------------------------------------------------------------------------------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| JobId | Label | State | Progress | Type | EtlInfo | TaskInfo | ErrorMsg | CreateTime | EtlStartTime | EtlFinishTime | LoadStartTime | LoadFinishTime | URL | JobDetails |
+-------+---------------------------+----------+---------------------+--------+---------------------------------------------------------+---------------------------------------------------------------------------------------------------------+----------+---------------------+---------------------+---------------------+---------------------+---------------------+--------------------------------------------------------------------------------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| 10082 | duplicate_table_with_null | FINISHED | ETL:100%; LOAD:100% | BROKER | unselected.rows=0; dpp.abnorm.ALL=0; dpp.norm.ALL=65546 | resource:N/A; timeout(s):300; max_filter_ratio:0.0 | NULL | 2022-08-02 14:53:27 | 2022-08-02 14:53:30 | 2022-08-02 14:53:30 | 2022-08-02 14:53:30 | 2022-08-02 14:53:31 | NULL | {"Unfinished backends":{"4393c992-5da1-4e9f-8b03-895dc0c96dbc":[]},"ScannedRows":65546,"TaskNumber":1,"All backends":{"4393c992-5da1-4e9f-8b03-895dc0c96dbc":[10002]},"FileNumber":1,"FileSize":548622} |
| 10103 | unique_table_with_null | FINISHED | ETL:100%; LOAD:100% | SPARK | unselected.rows=0; dpp.abnorm.ALL=0; dpp.norm.ALL=65546 | resource:test_spark_resource_07af473a_1230_11ed_b483_00163e0e550b; timeout(s):300; max_filter_ratio:0.0 | NULL | 2022-08-02 14:56:06 | 2022-08-02 14:56:19 | 2022-08-02 14:56:41 | 2022-08-02 14:56:41 | 2022-08-02 14:56:44 | http://emr-header-1.cluster-49091:20888/proxy/application_1655710334658_26391/ | {"Unfinished backends":{"00000000-0000-0000-0000-000000000000":[]},"ScannedRows":65546,"TaskNumber":1,"All backends":{"00000000-0000-0000-0000-000000000000":[-1]},"FileNumber":1,"FileSize":8790855} |
+-------+---------------------------+----------+---------------------+--------+---------------------------------------------------------+---------------------------------------------------------------------------------------------------------+----------+---------------------+---------------------+---------------------+---------------------+---------------------+--------------------------------------------------------------------------------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+

Пример 3: Отобразить загрузочные задания, метки которых содержат строку table в example_db. Кроме того, возвращаемые загрузочные задания отображаются в порядке убывания поля LoadStartTime.

SHOW LOAD FROM example_db
WHERE LABEL Like "table"
ORDER BY LoadStartTime DESC;

+-------+---------------------------+----------+---------------------+--------+---------------------------------------------------------+---------------------------------------------------------------------------------------------------------+----------+---------------------+---------------------+---------------------+---------------------+---------------------+--------------------------------------------------------------------------------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| JobId | Label | State | Progress | Type | EtlInfo | TaskInfo | ErrorMsg | CreateTime | EtlStartTime | EtlFinishTime | LoadStartTime | LoadFinishTime | URL | JobDetails |
+-------+---------------------------+----------+---------------------+--------+---------------------------------------------------------+---------------------------------------------------------------------------------------------------------+----------+---------------------+---------------------+---------------------+---------------------+---------------------+--------------------------------------------------------------------------------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| 10103 | unique_table_with_null | FINISHED | ETL:100%; LOAD:100% | SPARK | unselected.rows=0; dpp.abnorm.ALL=0; dpp.norm.ALL=65546 | resource:test_spark_resource_07af473a_1230_11ed_b483_00163e0e550b; timeout(s):300; max_filter_ratio:0.0 | NULL | 2022-08-02 14:56:06 | 2022-08-02 14:56:19 | 2022-08-02 14:56:41 | 2022-08-02 14:56:41 | 2022-08-02 14:56:44 | http://emr-header-1.cluster-49091:20888/proxy/application_1655710334658_26391/ | {"Unfinished backends":{"00000000-0000-0000-0000-000000000000":[]},"ScannedRows":65546,"TaskNumber":1,"All backends":{"00000000-0000-0000-0000-000000000000":[-1]},"FileNumber":1,"FileSize":8790855} |
| 10082 | duplicate_table_with_null | FINISHED | ETL:100%; LOAD:100% | BROKER | unselected.rows=0; dpp.abnorm.ALL=0; dpp.norm.ALL=65546 | resource:N/A; timeout(s):300; max_filter_ratio:0.0 | NULL | 2022-08-02 14:53:27 | 2022-08-02 14:53:30 | 2022-08-02 14:53:30 | 2022-08-02 14:53:30 | 2022-08-02 14:53:31 | NULL | {"Unfinished backends":{"4393c992-5da1-4e9f-8b03-895dc0c96dbc":[]},"ScannedRows":65546,"TaskNumber":1,"All backends":{"4393c992-5da1-4e9f-8b03-895dc0c96dbc":[10002]},"FileNumber":1,"FileSize":548622} |
+-------+---------------------------+----------+---------------------+--------+---------------------------------------------------------+---------------------------------------------------------------------------------------------------------+----------+---------------------+---------------------+---------------------+---------------------+---------------------+--------------------------------------------------------------------------------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+

Пример 4: Отобразить загрузочное задание с меткой duplicate_table_with_null и состоянием FINISHED в example_db.

SHOW LOAD FROM example_db
WHERE LABEL = "duplicate_table_with_null" AND STATE = "FINISHED";

+-------+---------------------------+----------+---------------------+--------+---------------------------------------------------------+----------------------------------------------------+----------+---------------------+---------------------+---------------------+---------------------+---------------------+------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| JobId | Label | State | Progress | Type | EtlInfo | TaskInfo | ErrorMsg | CreateTime | EtlStartTime | EtlFinishTime | LoadStartTime | LoadFinishTime | URL | JobDetails |
+-------+---------------------------+----------+---------------------+--------+---------------------------------------------------------+----------------------------------------------------+----------+---------------------+---------------------+---------------------+---------------------+---------------------+------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| 10082 | duplicate_table_with_null | FINISHED | ETL:100%; LOAD:100% | BROKER | unselected.rows=0; dpp.abnorm.ALL=0; dpp.norm.ALL=65546 | resource:N/A; timeout(s):300; max_filter_ratio:0.0 | NULL | 2022-08-02 14:53:27 | 2022-08-02 14:53:30 | 2022-08-02 14:53:30 | 2022-08-02 14:53:30 | 2022-08-02 14:53:31 | NULL | {"Unfinished backends":{"4393c992-5da1-4e9f-8b03-895dc0c96dbc":[]},"ScannedRows":65546,"TaskNumber":1,"All backends":{"4393c992-5da1-4e9f-8b03-895dc0c96dbc":[10002]},"FileNumber":1,"FileSize":548622} |
+-------+---------------------------+----------+---------------------+--------+---------------------------------------------------------+----------------------------------------------------+----------+---------------------+---------------------+---------------------+---------------------+---------------------+------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+

Пример 5: Пропустить первое загрузочное задание и отобразить следующие два загрузочных задания. Кроме того, эти два загрузочных задания сортируются по возрастанию.

SHOW LOAD FROM example_db
ORDER BY CreateTime ASC
LIMIT 2 OFFSET 1;

Или

SHOW LOAD FROM example_db
ORDER BY CreateTime ASC
LIMIT 1,2;

Вывод вышеуказанных команд выглядит следующим образом.

+-------+---------------------------------------------+----------+---------------------+--------+---------------------------------------------------------+---------------------------------------------------------------------------------------------------------+----------+---------------------+---------------------+---------------------+---------------------+---------------------+--------------------------------------------------------------------------------+-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| JobId | Label | State | Progress | Type | EtlInfo | TaskInfo | ErrorMsg | CreateTime | EtlStartTime | EtlFinishTime | LoadStartTime | LoadFinishTime | URL | JobDetails |
+-------+---------------------------------------------+----------+---------------------+--------+---------------------------------------------------------+---------------------------------------------------------------------------------------------------------+----------+---------------------+---------------------+---------------------+---------------------+---------------------+--------------------------------------------------------------------------------+-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| 10103 | unique_table_with_null | FINISHED | ETL:100%; LOAD:100% | SPARK | unselected.rows=0; dpp.abnorm.ALL=0; dpp.norm.ALL=65546 | resource:test_spark_resource_07af473a_1230_11ed_b483_00163e0e550b; timeout(s):300; max_filter_ratio:0.0 | NULL | 2022-08-02 14:56:06 | 2022-08-02 14:56:19 | 2022-08-02 14:56:41 | 2022-08-02 14:56:41 | 2022-08-02 14:56:44 | http://emr-header-1.cluster-49091:20888/proxy/application_1655710334658_26391/ | {"Unfinished backends":{"00000000-0000-0000-0000-000000000000":[]},"ScannedRows":65546,"TaskNumber":1,"All backends":{"00000000-0000-0000-0000-000000000000":[-1]},"FileNumber":1,"FileSize":8790855} |
| 10120 | insert_3a57b595-1230-11ed-b075-00163e14c85e | FINISHED | ETL:100%; LOAD:100% | INSERT | NULL | resource:N/A; timeout(s):3600; max_filter_ratio:0.0 | NULL | 2022-08-02 14:56:26 | 2022-08-02 14:56:26 | 2022-08-02 14:56:26 | 2022-08-02 14:56:26 | 2022-08-02 14:56:26 | | {"Unfinished backends":{},"ScannedRows":0,"TaskNumber":0,"All backends":{},"FileNumber":0,"FileSize":0} |
+-------+---------------------------------------------+----------+---------------------+--------+---------------------------------------------------------+---------------------------------------------------------------------------------------------------------+----------+---------------------+---------------------+---------------------+---------------------+---------------------+--------------------------------------------------------------------------------+-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+