flink集群与资源@k8s源码分析-运行时

1 运行时

运行时提供了Flink作业运行过程依赖的基础执行环境，包含Dispatcher、ResourceManager、JobManager和TaskManager等核心组件，本节分析资源相关运行时组件构建和启动。

flink没有使用spring，缺少ioc的构建过程相当复杂，所有依赖手动关联和置入，为了共享组件，flink使用了很多中间持有共享组件的中间对象。

2 场景

3 构建和启动flink master组件

部署集群通过flink kubeclient向k8s集群管理提交flink master的Deployment，触发flink master构建和启动

上图是构建和启动的交互图，参看《构建作业管理器部署规格》的CmdJobManagerDecorator设置了初始容器脚本和参数，集群初始入口ClusterEntryPoint

1. 容器初始执行kubernetes-jobmanager.sh

ClusterEntryPoint设置为KubernetesSessionClusterEntrypoint

2.
KubernetesSessionClusterEntrypoint继承SessionClusterEntrypoint，只重新实现createDispatcherResourceManagerComponentFactory方法&