TERMINATE

TERMINATE语句用于终止Flink任务。

引擎与版本

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

说明

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

语法

terminate_job_statement ::= TERMINATE JOB job_name

使用说明

job_name为正在运行的Flink任务名称。您可以通过DESCRIBE语句查看指定Flink任务的状态是否为RUNNING(运行中)。

示例

终止任务test_datagen2

TERMINATE JOB test_datagen2;

结果验证

您可以通过SHOW JOBS;来查看test_datagen2的状态,执行成功后Job Status将显示CANCELED