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

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内のすべてのルーチンロードジョブ（停止またはキャンセルされたものを含む）を表示します。結果は1行または複数行になる場合があります。

    use example_db;
    SHOW ALL ROUTINE LOAD;

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

    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;