简介
本系列是flink源码分析的第二个系列,上一个《flink源码分析之集群与资源》分析集群与资源,本系列分析功能组件,kubeclient,rpc,心跳,高可用,slotpool,rest,metrics,future。
本文解释高可用组件,包括两项服务,主节点选举和主节点变更通知*
高可用服务常见有两种实现,zookeeper和k8s,本文介绍zookeeper
*flink高可用组件还有作业状态,作业存储,作业结果存储服务,这些放到作业执行系列分析,本章暂不涉及
设计
上图是高可用包结构,也体现