spark job提交流程源碼

目錄正則表達式   #Job提交流程概覽數組 #Task類型app 1.Taskide 2.DAGTaskfetch 3.ResultTaskthis 4.ShuffleMapTaskspa #Stage劃分線程 sc.runJobcode DAGScheduler.runJoborm submitStage() getMissingParentStages() getShuffleMapStag
相關文章
相關標籤/搜索