在 JobManager 启动时,调用
HighAvailabilityServicesUtils.createHighAvailabilityServices 来创建 HA 服务,HA 依赖的服务都被封装在 HighAvailabilityServices 中。当前 Flink 内部支持两种高可用模式,分别是 ZooKeeper 和 KUBERNETES。
Flink源码阅读:JobManager的HA机制
未经允许不得转载:小狮博客 » Flink源码阅读:JobManager的HA机制
小狮博客