Flink 1.9源码学习04 ----Job启动Driver端

1，整个Flink的Job启动是通过在Driver端通过用户的Envirement的execute()方法将用户的算子转化成StreamGraph 2，然后得到JobGraph通过远程RPC将这个JobGraph提交到JobManager对应的接口 3，JobManager转化成executionGraph.deploy()，然后生成TDD发给TaskManager，然后整个Job就启动起来了 这

>>阅读原文<<