Spark源码分析——Task的调度
DAGScheduler.submitMissingTasks(stage: Stage, jobId: Int) 方法中的最后几行,有一个 taskScheduler.submitTasks(new TaskSet( tas[......]
DAGScheduler.submitMissingTasks(stage: Stage, jobId: Int)
taskScheduler.submitTasks(new TaskSet( tas[......]
Read more
近期评论