SHOW LOAD

SHOW LOAD отображает информацию о всех задачах загрузки или заданных задачах загрузки в базе данных. Эта инструкция может отображать только задачи загрузки, созданные с помощью Broker Load, INSERT и SPARK_LOAD. Вы также можете просматривать информацию о задачах загрузки через команду curl. Начиная с версии 1.5.0, мы рекомендуем использовать инструкцию 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 Load	Spark Load	INSERT
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.
URL	URL, который используется для доступа к некачественным данным, обнаруженным в задаче загрузки. Вы можете использовать команду `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}                                                                                               |
+-------+---------------------------------------------+----------+---------------------+--------+---------------------------------------------------------+---------------------------------------------------------------------------------------------------------+----------+---------------------+---------------------+---------------------+---------------------+---------------------+--------------------------------------------------------------------------------+-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+

Синтаксис​

Параметры​

Вывод​

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

Примеры​

Синтаксис

Параметры

Вывод

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

Примеры