DESCRIBE 文は、Flink ジョブの詳細を表示します。
エンジンとバージョン
DESCRIBE 文は、ストリームエンジンにのみ適用され、バージョン 3.1.8 以降が必要です。
説明
コンソールを使用してエンジンバージョンを表示し、マイナーバージョンアップデートを実行できます。
構文
describe_statement ::= { DESCRIBE | DESC } name使用上の注意
name は Flink ジョブの名前です。SHOW JOBS 文を使用して、現在のリソースグループ内の Flink ジョブを表示できます。
例
datagen_job ジョブの詳細を表示します。
DESC datagen_job \G;説明
\G を追加すると、結果が垂直フォーマットで表示され、読みやすくなります。
出力:
*************************** 1. row ***************************
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;