spark job提交流程源码

目录正则表达式   #Job提交流程概览数组 #Task类型app 1.Taskide 2.DAGTaskfetch 3.ResultTaskthis 4.ShuffleMapTaskspa #Stage划分线程 sc.runJobcode DAGScheduler.runJoborm submitStage() getMissingParentStages() getShuffleMapStag
相关文章
相关标签/搜索