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

0 介绍

本文是flink集群与资源@k8s源码分析系列的第二篇-集群

1 场景

下面详细分析各用例

2 启动k8s集群

k8s集群支持session和application模式，job模式将会被废弃，本文分析session模式集群

Configuration作为配置容器，几乎所有的构建需要从配置类获取配置项，这里不显示关联关系

1. 用户命令行执行kubernates-session.sh，主入口是KubernetesSessionCli main

2.
ClusterClientServiceLoader SPI机制载入ClusterClientFactory，k8s环境下实现类是KubernetesClusterClientFactory

3. ClusterClientFactory是ClusterClient工厂，首先创建ClusterDescriptor集群描述，该类负责部署集群，最终返回ClusterClient，k8s环境下实现类是
KubernetesClusterDescriptor

4.
KubernetesClusterDescriptor新建集群规格ClusterSpecification，该类不是针对k8s，定义了flink master和任务管理器<