Spark源码分析 -- TaskScheduler
Spark在设计上将DAGScheduler和TaskScheduler完全解耦合, 所以在资源管理和task调度上可以有更多的方案 现在支持,LocalSheduler,ClusterScheduler,MesosScheduler, YarnClusterScheduler 先分析ClusterScheduler, 即standalone的Spark集群上, 因为比较单纯不涉及其他的系统, 看看Spark的任务是如何被执行的 private var taskScheduler: TaskScheduler = { case SPARK_REGEX(sparkUrl) => val scheduler = new ClusterScheduler(this) // 创建ClusterScheduler val backend = new SparkDeploySchedulerBackend(scheduler, this, sparkUrl, appName) // 创建SparkDeploySchedulerBackend scheduler.initialize(bac...