网站开发完后部署到网上,马洪旭 做的网站大学,访问wordpress时失败,美橙互联网站管理后台0 介绍
本文是flink集群与资源@k8s源码分析系列的第二篇-集群
1 场景 下面详细分析各用例
2 启动k8s集群
k8s集群支持session和application模式,job模式将会被废弃,本文分析session模式集群 Configuration作为配置容器,几乎所有的构建需要从配置类获取配置项,这里不显示…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和任务管理器