Spark源碼分析之Scheduler模塊(TaskScheduler)

DAGScheduler將任務提交到TaskScheduler之後，接下來由TaskScheduler負責任務的調度。 TaskScheduler是一個trait（接口類），它的實現類是TaskSchedulerImpl。具體內容包括： 1、出現shuffle輸出lost要報告fetch failed錯誤 2、碰到straggle任務需要放到別的節點上重試 3、爲每個TaskSet維護一個Task

>>阅读原文<<