PerJob 模式下，在作业完全挂掉之后，是会上报 YARN RM 应用自己失败的状态的。
当然，在 FLINK 察觉自己 FAILED 到上报给 YARN 是有一定的时延的，也有可能因为网络等问题上报失败。 你这个是短暂的不一致时间窗口，还是说 FLINK 集群已经退了，YARN 的状态还没有变化呢？ Best, tison. zhisheng <[email protected]> 于2020年11月12日周四 下午8:17写道： > 同遇见过这个问题，所以作业监控告警的时候一般都是拿作业所有的 task 级别的状态，而不是简单的 yarn 状态 > > hdxg1101300123 <[email protected]> 于2020年11月12日周四 下午8:07写道： > > > 可以设置检查点失败任务也失败 > > > > > > > > 发自vivo智能手机 > > > hi everyone, > > > > > > 最近在使用Flink-1.11.1 On Yarn Per > > Job模式提交简单的kafka->mysql任务时，发现当有脏数据或mysql主键限制等等原因导致Flink任务状态置为Failed时，Yarn > > application仍处于运行状态 > > > > > > 疑问是Flink任务处于Failed或Finished时，不会反馈自身状态给Yarn吗？期待大佬解惑，谢谢 > > > > > > best, > > > amenhub >
