DESCRIBE

DESCRIBE语句用于打印Flink任务(JOB)的详细信息。

引擎与版本

DESCRIBE仅适用于流引擎。要求3.1.8及以上版本。

说明

您可以通过控制台查看并升级小版本

语法

describe_statement ::= { DESCRIBE | DESC } name

使用说明

nameFlink任务的名称。您可以通过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;