Flink 源碼解讀系列 | Flink的Job啓動Driver端

點擊上方藍色字體,選擇「設爲星標」 回覆」資源「獲取更多驚喜 大數據技術與架構 點擊右側關注,大數據開發領域最強公衆號! 暴走大數據 點擊右側關注,暴走大數據! 整個Flink的Job啓動是通過在Driver端通過用戶的Envirement的execute()方法將用戶的算子轉化成StreamGraph 然後得到JobGraph通過遠程RPC將這個JobGraph提交到JobManager對應的接
相關文章
相關標籤/搜索