メインコンテンツまでスキップ
バージョン: 2.1

SHOW ROUTINE LOAD

デスクリプション

このステートメントは、Routine Load ジョブの実行ステータスを表示するために使用されます。特定のジョブまたはすべてのジョブのステータス情報を表示できます。

Syntax

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

オプションパラメータ

1. [ALL]

オプションパラメータ。指定した場合、すべてのジョブ(停止またはキャンセルされたジョブを含む)が表示されます。指定しない場合、現在実行中のジョブのみが表示されます。

2. [FOR <jobName>]

オプションパラメータ。表示するジョブ名を指定します。指定しない場合、現在のデータベース下のすべてのジョブが表示されます。

以下の形式をサポートします:

  • <job_name>:現在のデータベース内で指定された名前のジョブを表示
  • <db_name>.<job_name>:指定されたデータベース内で指定された名前のジョブを表示

戻り値

フィールド名説明
IdジョブID
Nameジョブ名
CreateTimeジョブ作成時刻
PauseTime最新のジョブ一時停止時刻
EndTimeジョブ終了時刻
DbName対応するデータベース名
TableName対応するTable名(複数Tableの場合は'multi-table'と表示)
IsMultiTblマルチTableジョブかどうか
Stateジョブ実行ステータス
DataSourceTypeデータソースタイプ:KAFKA
CurrentTaskNum現在のサブタスク数
JobPropertiesジョブ設定詳細
DataSourcePropertiesデータソース設定詳細
CustomPropertiesカスタム設定
Statisticジョブ実行統計
Progressジョブ実行進捗
Lagジョブ遅延ステータス
ReasonOfStateChangedジョブ状態変更理由
ErrorLogUrls品質チェックに失敗したフィルタリングデータを表示するURL
OtherMsgその他のエラーメッセージ

アクセス制御要件

このSQLコマンドを実行するユーザーは、少なくとも以下の権限を持つ必要があります:

権限オブジェクト備考
LOAD_PRIVTableSHOW ROUTINE LOADはTableに対するLOAD権限が必要です

注意事項

  • State の説明:

    • NEED_SCHEDULE:ジョブはスケジュール待ち
    • RUNNING:ジョブは実行中
    • PAUSED:ジョブは一時停止中
    • STOPPED:ジョブは終了済み
    • CANCELLED:ジョブはキャンセル済み
  • Progress の説明:

    • Kafkaデータソースの場合、各パーティションの消費オフセットを表示
    • 例:{"0":"2"} はKafkaパーティション0の消費進捗が2であることを意味
  • Lag の説明:

    • Kafkaデータソースの場合、各パーティションの消費遅延を表示
    • 例:{"0":10} はKafkaパーティション0の消費遅延が10であることを意味

  • test1という名前のすべてのroutine loadジョブ(停止またはキャンセルされたものを含む)を表示

    SHOW ALL ROUTINE LOAD FOR test1;
  • test1という名前で現在実行中のroutine loadジョブを表示する

    SHOW ROUTINE LOAD FOR test1;
  • example_db内のすべてのroutine loadジョブ(停止またはキャンセルされたものを含む)を表示します。結果は1行または複数行になる場合があります。

    use example_db;
    SHOW ALL ROUTINE LOAD;

example_db内で現在実行中のすべてのroutine loadジョブを表示する

```sql
use example_db;
SHOW ROUTINE LOAD;
```
  • example_db内のtest1という名前で現在実行中のroutine load jobを表示する

    SHOW ROUTINE LOAD FOR example_db.test1;
  • example_db内のtest1という名前のすべてのroutine loadジョブ(停止またはキャンセルされたものを含む)を表示します。結果は1行または複数行になる場合があります。

    SHOW ALL ROUTINE LOAD FOR example_db.test1;