1. 程式人生 > >DAGScheduler原始碼分析stage劃分演算法,task最佳位置計算演算法

DAGScheduler原始碼分析stage劃分演算法,task最佳位置計算演算法

在DAGScheduler類中的HandleJobSubmitted是job排程的核心入口

進入了newStage()方法它會建立一個stage物件

進入submitStage()方法

進入getMissingParentStages方法()

進入submitWaitingStages()方法

stage劃分演算法總結

1,從finalStage倒推

2,通過寬依賴,來進行新的stage的劃分

3,使用遞迴優先提交父stage

接下來是stage會建立task

進入getPreFerredLocasInternal()方法(task最佳位置計算演算法)