spark job提交過程

Driver的任務提交過程web 一、Driver程序的代碼運行到action操做,觸發了SparkContext的runJob方法。 二、SparkContext調用DAGScheduler的runJob函數。 三、DAGScheduler把Job劃分stage,而後把stage轉化爲相應的Tasks,把Tasks交給TaskScheduler。 四、經過TaskScheduler把Tasks添
相關文章
相關標籤/搜索