引擎与版本
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。