DAGScheduler源碼分析stage劃分算法,task最佳位置計算算法

在DAGScheduler類中的HandleJobSubmitted是job調度的核心入口 進入了newStage()方法它會創建一個stage對象 進入submitStage()方法 進入getMissingParentStages方法() 進入submitWaitingStages()方法 stage劃分算法總結 1,從finalStage倒推 2,通過寬依賴,來進行新的stage的劃分 3,
相關文章
相關標籤/搜索