Spark內核之DAGScheduler調度

Executor啓動完了,接下來就準備在executor上執行task了,關於task任務的執行,就是我們接下來要說的TaskScheduler和DAGScheduler了。 TaskScheduler作用是爲創建它的SparkContext調度任務,即從DAGScheduler接受不同Stage的任務,並且向集羣提交這些任務 DAGScheduler主要負責分析用戶提交的應用,並根據計算任務的依
相關文章
相關標籤/搜索