Flink内核解析_提交流程_执行用户代码

执行用户代码，首先是找到 StreamExecutionEnvironment类 进入 此类下

执行的时候要用 execute(）层层调用，要求传东西，其实传不传都是可以的！（点进去）再次点进去再点进去 查看查看到很多衍生类，有部署在本地的，Yarn的，K8s的，等等。下面回退
将用户的代码传进来继续按住ctrl + t点击页面如下，将流程图转换为作业图创建了一个集群描述器，点击进去看一眼。点击Yarn 注意：上面两个有绿色模块，含义代表是还在测试阶段。并不是真正意义的公布。点进去继续点进去。里面有yarn配置，Flink配置，上下文配置，集群客户端配置等等。返回，返回返回，返回！！

到如下页面
集群的配置，拿到了描述信息，将描述信息丢进去getClusterSpecificatior方法中进入后点击

设置，设置job内存，task内存， 槽内存等等。返回，返回，在返回！！

一句话总结
下一步：这个是描述器。调用了 deployJobCluster方法
集群，作业图全部传过来了，

继续点进去

继续点进

到了498行开始 查看

持续查看

执行到这里，就算是是结束了。