spark内核揭秘-09-RDD的count操作 触发Job全生命周期-02

接着上一篇文章继续分析代码： 3.1.3.3.3.1、进入TaskSet 方法： 3.1.3.3.3.2、进入taskScheduler.submitTasks(new TaskSet(tasks.toArray, stage.id, stage.newAttemptId(), stage.jobId, properties)) 方法： 从源代码中可以看出DAGScheduler中向TaskSch

>>阅读原文<<