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/

回复