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就啓動起來了 這

>>阅读原文<<