Spark作業提交執行流程源碼圖

環境：代碼圖基於Spark 2.2.1 工具：OmniGraffe 最近想完整梳理一下作業提交流程，通過自己的理解畫圖來學習Spark。 1） 首先了解作業提交後RDD的流動情況 如上圖，以RDD構建的DAG給DAGScheduler進行stage劃分，DAGScheduler負責stage層面的提交和失敗處理。 然後提交taskSet給TaskScheduler進行處理，TaskSchedule

>>阅读原文<<