YARN AM 包含了 Dispatcher/Resource Manager/JobManager，AM 挂掉的时候 YARN 会负责拉起来 一个相同配置的 AM。
Flink 自身的高可用，per job 模式下，CheckpointStore 基于 ZooKeeper 和 HDFS 来做，可以保证。 JobGraphStore 存在内存里，不是高可用的，但是每次新拉起来的 AM 都带有用户提交的 JobGraph 信息， 所以新拉起来的 Dispatcher 也能从中知道 JobGraph 的内容。 Best, tison. Zhenghua Gao <[email protected]> 于2019年8月13日周二 下午5:02写道： > JM is restarted by YARN on failure [1]. > > [1] > > https://ci.apache.org/projects/flink/flink-docs-stable/ops/jobmanager_high_availability.html#yarn-cluster-high-availability > > *Best Regards,* > *Zhenghua Gao* > > > On Tue, Aug 13, 2019 at 4:51 PM 陈帅 <[email protected]> wrote: > > > 请教一下：flink on yarn，提交方式是per job的话，如何保证高可用？ > > >
