入口类

Session Client 入口类
FlinkYarnSessionCli
�

CliFrontend不会读flink-conf.yaml配置文件
buildProgram

�JobManager端口

每个任务会创建一个JobMaster
类加载器在JobMasterServiceLeadershipRunnerFactory中创建
代码如下
�

final ClassLoader userCodeClassLoader =
        classLoaderLease
                .getOrResolveClassLoader(
                        jobGraph.getUserJarBlobKeys(), jobGraph.getClasspaths())
                .asClassLoader();

JobGraph
userJars 包含connector

�