FLinkFlink 任务 如何优雅的停止

Posted 2022-07-28 九师兄

文章目录

• 1.概述
• 2.正确的关闭
• • 2.1 在ui界面停止
  • 2.2 在命令行停止
  • 2.3 也可以调用远程地址
• 3. 我们的问题

1.概述

在进行测试的时候，发现就是yarn-per job 模式运行flink ,然后使用yarn api 调用Yarn关闭flink任务，直接 yarnClient.killApplication(ApplicationId)方法，然后发现没有调用flink function的 close方法。

但是如果手动到flink ui 界面先cancel，然后在调用关闭方法，就会执行close方法

难道yarn close方法 是直接干掉了 容器，都不给flink反应时间？

后来验证是我们关闭方式太暴力了。

yarnClient.killApplication(