メインコンテンツまでスキップ
に最終更新

SHOW ROUTINE LOAD

説明​

このステートメントは、Routine Load ジョブの実行状態を表示します。特定のジョブ、またはすべてのジョブの状態情報を確認できます。

構文​

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対応するテーブル名。複数のテーブルを対象とする場合は 'multi-table' と表示されます。
IsMultiTable複数テーブルを対象とするジョブかどうか
Stateジョブの実行状態
DataSourceTypeデータソースの種類: KAFKA
CurrentTaskNum現在のサブタスク数
JobPropertiesジョブの設定の詳細
DataSourcePropertiesデータソースの設定の詳細
CustomPropertiesカスタム設定。機密プロパティは ****** と表示されます。詳細は以下の「機密プロパティのマスキング」を参照してください。
Statisticジョブの実行統計
Progressジョブの実行進捗
Lagジョブの遅延状態
ReasonOfStateChangedジョブの状態が変わった理由
ErrorLogUrls品質チェックに失敗し、除外されたデータを確認するための URL
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.key のいずれかで終わるssl.keystore.password、sasl.oauthbearer.client.secret
.session_key または .session.token で終わるaws.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 以降、このテーブルは master FE が提供するため、クエリが master 以外の FE に送られた場合も FIRST_ERROR_MSG と ERROR_LOG_URLS は空になりません。

アクセス制御要件​

この 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 であることを示します。

例​

  • test1 という名前の Routine Load ジョブを、停止またはキャンセルされたものも含めてすべて表示します。

    SHOW ALL ROUTINE LOAD FOR test1;

  • test1 という名前で現在実行中の Routine Load ジョブを表示します。

    SHOW ROUTINE LOAD FOR test1;

  • example_db 内の Routine Load ジョブを、停止またはキャンセルされたものも含めてすべて表示します。結果は単一行または複数行になる場合があります。

    use example_db;
    SHOW ALL ROUTINE LOAD;

  • example_db 内で現在実行中の Routine Load ジョブをすべて表示します。

    use example_db;
    SHOW ROUTINE LOAD;

  • example_db 内で test1 という名前の現在実行中の Routine Load ジョブを表示します。

    SHOW ROUTINE LOAD FOR example_db.test1;

  • example_db 内で test1 という名前の Routine Load ジョブを、停止またはキャンセルされたものも含めてすべて表示します。結果は単一行または複数行になる場合があります。

    SHOW ALL ROUTINE LOAD FOR example_db.test1;
Report issue