大話Spark(9)-源碼之TaskScheduler

上篇文章講到DAGScheduler會把job劃分爲多個Stage,每個Stage中都會創建一批Task,然後把Task封裝爲TaskSet提交到TaskScheduler。 這裏我們來一起看下TaskScheduler是如何把Task分配到應用程序的Executor上去執行。 重點是這裏的task分配算法。 如下圖是DagScheduler中把TaskSet提交到TaskScheduler: 這
相關文章
相關標籤/搜索