【FLink】Flink 任务如何优雅的停止

1.概述

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

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

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

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

yarnClient.killApplication(

相关阅读:
Spring IOC
计算机毕业设计SSM订餐系统【附源码数据库】
景区门票小程序怎么制作？
【ES】一、ES入门及JavaAPI使用
通过Python Pandas分析数据上涨下跌趋势的方法：求离散数据的差分、导数
MybatisPlus 原理学习：一张图了解 mybatisplus 查询流程
python数据分析(3)
G1垃圾收集器
位移运算法的解释与hashMap的应用。
CentOS8挂载本地ISO 配置本地YUM源

原文地址：https://blog.csdn.net/qq_21383435/article/details/124719051