flink重启机制

[chenyu_opensource]

你好，flink任务提交到yarn上，由于某个节点下线导致flink任务失败，如下：


同时重试超过次数，任务失败，如下图：


我想问一下，flink重试机制中 
任务不会重新调度到新节点的container吗？为什么一直在同一个节点从而导致整体任务失败。这个调度是由yarn控制还是flink自身代码控制的？如有相关代码也请告知，谢谢。


期待回复，谢谢!