Spark源碼分析之三：Stage劃分

        繼上篇《Spark源碼分析之Job的調度模型與運行反饋》以後，咱們繼續來看第二階段--Stage劃分。java         Stage劃分的大致流程以下圖所示：數組         前面提到，對於JobSubmitted事件，咱們經過調用DAGScheduler的handleJobSubmitted()方法來處理。那麼咱們先來看下代碼：緩存 // 處理Job提交的函數 pr

>>阅读原文<<