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

SHOW ROUTINE LOAD TASK

説明​

この構文は、指定した Routine Load ジョブで現在実行中のサブタスクを表示するために使用します。

構文​

SHOW ROUTINE LOAD TASK WHERE JobName = <job_name>;

SHOW ROUTINE LOAD TASK FOR [<db>.]<job_name>;

必須パラメータ​

1. <job_name>

表示する Routine Load ジョブの名前を指定します。

オプションパラメータ​

1. <db>

Routine Load ジョブが属するデータベース。省略した場合は、現在のデータベースで Routine Load ジョブを検索します。

返却結果​

返却結果には、次のフィールドが含まれます。

フィールド名説明
TaskIdサブタスクの一意の ID
TxnIdサブタスクに対応するインポートトランザクションの ID
TxnStatusサブタスクのインポートトランザクションの状態。Null は、サブタスクがまだスケジュールされていないことを示します
JobIdサブタスクに対応するジョブの ID
CreateTimeサブタスクの作成時刻
ExecuteStartTimeサブタスクの実行がスケジュールされた時刻。通常は作成時刻より後です
Timeoutサブタスクのタイムアウト。通常はジョブに設定された max_batch_interval の二倍です
BeIdこのサブタスクを実行する BE ノードの ID
DataSourcePropertiesサブタスクが消費を開始する予定の Kafka パーティションの開始オフセット。JSON 形式の文字列で、キーはパーティション ID、値は消費の開始オフセットです

必要な権限​

この SQL コマンドを実行するユーザーには、少なくとも次の権限が必要です。

権限対象説明
LOAD_PRIVテーブルSHOW ROUTINE LOAD TASK には、テーブルに対する LOAD 権限が必要です

使用上の注意​

  • TxnStatus が null でも、タスクにエラーが発生したとは限りません。タスクがまだスケジュールされていない可能性があります。
  • DataSourceProperties のオフセット情報は、データの消費状況を追跡するために使用できます。
  • Timeout に達すると、データの消費が完了しているかどうかにかかわらず、タスクは自動的に終了します。

例​

  • test1 という名前の Routine Load タスクのサブタスク情報を表示します。

    SHOW ROUTINE LOAD TASK WHERE JobName = "test1";

  • 現在のデータベースにある Routine Load ジョブ test1 のサブタスク情報を表示します。

    SHOW ROUTINE LOAD TASK FOR test1;

  • Routine Load ジョブ test1 がデータベース example_db にある場合、そのサブタスク情報を表示します。

    SHOW ROUTINE LOAD TASK FOR example_db.test1;
Report issue