DESCRIBE(または DESC)コマンドを使用すると、Flink ジョブのステータス、実行時間、およびフル SQL 定義を含む詳細情報を表示できます。
エンジンとバージョン
DESCRIBE はストリームエンジンのみで使用可能であり、バージョン 3.1.8 以降が必要です。
現在のエンジンバージョンを確認、またはアップグレードするには、コンソールを使用してください。詳細については、「ApsaraDB for Lindorm インスタンスのマイナーエンジンバージョンをアップグレードする」をご参照ください。
構文
{ DESCRIBE | DESC } namename は Flink ジョブの名前です。現在のリソースグループに存在するすべてのジョブを一覧表示するには、SHOW JOBS を実行します。
例
datagen_job ジョブの詳細情報を表示します:
DESC datagen_job \G;出力例:
*************************** 1. 行 ***************************
Query ID: datagen_job
Job ID: 0021dcbf7633ed1b4c5a64a59591****
Status: RUNNING
Is Stoppable: false
Start time: 1753952195254
End time: -1
Duration: 61348039
Max Parallelism: -1
DelayMs: -1.0
Sql:
SET 'parallelism.default' = '6';
CREATE TABLE datagen (
f_sequence INT,
f_random INT,
f_random_str STRING,
ts AS localtimestamp,
WATERMARK FOR ts AS ts
) WITH (
'connector' = 'datagen',
'rows-per-second'='5',
'fields.f_sequence.kind'='sequence',
'fields.f_sequence.start'='1',
'fields.f_sequence.end'='50000000',
'fields.f_random.min'='1',
'fields.f_random.max'='500',
'fields.f_random_str.length'='10'
);
CREATE TABLE print_table (
f_sequence INT,
f_random INT,
f_random_str STRING
) WITH (
'connector' = 'print'
);
INSERT INTO print_table select f_sequence,f_random,f_random_str from datagen;\G を付加すると、結果が縦方向フォーマットで表示され、読みやすくなります。出力フィールド
| フィールド | 説明 |
|---|---|
| Query ID | DESCRIBE 文で指定した Flink ジョブの名前です。 |
| Job ID | ストリームエンジンがジョブに割り当てた一意の識別子です。 |
| Status | ジョブの現在のステータスです。主な値: RUNNING、FINISHED、FAILED、CANCELED。 |
| Is Stoppable | セーブポイントを使用してジョブを停止できるかどうかを示します。false の場合、セーブポイントによる停止はサポートされていません。 |
| Start time | ジョブの開始時刻(ミリ秒単位の UNIX タイムスタンプ)です。 |
| End time | ジョブの終了時刻(ミリ秒単位の UNIX タイムスタンプ)です。-1 の場合、ジョブはまだ実行中です。 |
| Duration | ジョブの実行時間(ミリ秒単位)です。 |
| Max Parallelism | ジョブに対して設定された最大並列数です。-1 の場合、明示的な制限は設定されていません。 |
| DelayMs | 処理遅延(ミリ秒単位)です。-1.0 の場合、遅延データは利用できません。 |
| Sql | ジョブとともに送信されたフル SQL 定義です。 |
次のステップ
SQL 定義を含まないジョブの詳細情報を表示するには、Lindorm コンソールの ジョブ ページに移動します。
現在のリソースグループに存在するすべてのジョブを一覧表示するには、SHOW JOBS を使用します。