1、简单粗暴控制台中Ctrl+C
2、UI中点击"Cancel"
3、执行cancel命令,需要知道Flink的Job ID
4、每个ExecutionGraph具有与其相关联的作业状态。此作业状态指示作业执行的当前状态。
5、Flink job首先处于创建状态,然后切换到运行状态,并且在完成所有工作后,它将切换到完成状态。在失败的情况下,job切换到第一个失败点,即取消所有正在运行任务的地方。如果所有job节点都已达到最终(或者说不可更改)状态,并且job不可重新启动,则job将转换为失败。如果作业可以重新启动,那么它将进入重新启动状态。一旦完成重新启动,它将变成创建状态。
6、在用户取消作业的情况下,将进入取消状态,这需要取消所有当前正在运行的任务。一旦所有运行的任务已经达到最终(或者说不可更改)状态,该作业将转换到已取消状态。
7、与完成状态不同,取消状态和失败咽疖纲掇状态表示一个全局的终端状态,并且触发清理工作,而暂停状态仅处于本地终端上。本地终端意味着job的执行已在相应的JobManager上终止,但Fl足毂忍珩ink集群的另一个JobManager可以从持久的HA存储中恢复这个job并重新启动。因此,处于暂停状态的job将不会被完全清理。