Flink 1.9源碼學習05 ----Job啓動JobManager端源碼分析

Driver將用戶代碼轉換成streamGraph再轉換成Jobgraph後向Jobmanager端提交 JobManager啓動以後會在Dispatcher.java起來RPC方法submitJob(jobGraph),用於接收來自Driver轉化得到的JobGraph來啓動任務 具體來看jobGraph提交到JobManager的submitJob方法 package org.apache.f
相關文章
相關標籤/搜索