Flink源码阅读:JobManager的HA机制

在 JobManager 启动时,调用
HighAvailabilityServicesUtils.createHighAvailabilityServices 来创建 HA 服务,HA 依赖的服务都被封装在 HighAvailabilityServices 中。当前 Flink 内部支持两种高可用模式,分别是 ZooKeeper 和 KUBERNETES。

赞(0)
未经允许不得转载:小狮博客 » Flink源码阅读:JobManager的HA机制
分享到: 更多 (0)

联系我们