hi 1.确定提交的是Per-job模式,提交命令是./bin/flink run -m yarn-cluster xxx,并且从Flink web ui中的Job Manager -> Configuration观察到execution.target值为yarn-per-job 2.整体任务状态为Failed,但是TM挂了,JM没有挂(没有挂的原因猜测是因为Yarn application还在Running的原因吧?所以还能从Job Manager -> logs查看失败日志内容)
best, amenhub 发件人: JasonLee 发送时间: 2020-11-13 11:22 收件人: user-zh 主题: Re: Flink与Yarn的状态一致性问题 hi 1,首先确定你提交的是per-job模式吗? 2,你说的任务状态是说jm还在任务在failover,还是任务确实是挂了,jm已经退出了? ----- Best Wishes JasonLee -- Sent from: http://apache-flink.147419.n8.nabble.com/