6.3 从Application提交的角度看重新审视Driver
6.3.1 Driver到底是什么时候产生的
在SparkContext实例化的时候通过createTaskScheduler来创建TaskSchedulerImpl和StandaloneSchedulerBackend。
SparkContext.scala源码:
1. class SparkContext(config: SparkConf) extends Logging {
2. ……..
3. val (sched, ts) = SparkContext.createTaskScheduler(this, master,deployMode)
4. _schedulerBackend = sched
5. _taskScheduler = ts
6.
7. _dagScheduler = newDAGScheduler(this)
8. _heartbeatReceiver.ask[Boolean](TaskSchedulerIsSet)
9. ……
10. private def createTaskScheduler(
11. .......
12. case SPARK_REGEX(sparkUrl)=>
13.