You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by "amenhub@163.com" <am...@163.com> on 2020/11/10 01:58:55 UTC

Flink与Yarn的状态一致性问题

hi everyone,

最近在使用Flink-1.11.1 On Yarn Per Job模式提交简单的kafka->mysql任务时，发现当有脏数据或mysql主键限制等等原因导致Flink任务状态置为Failed时，Yarn application仍处于运行状态

疑问是Flink任务处于Failed或Finished时，不会反馈自身状态给Yarn吗？期待大佬解惑，谢谢

best,
amenhub