《深入理解Spark:核心思想与源码分析》——3.6节创建任务调度器TaskScheduler
本节书摘来自华章社区《深入理解Spark:核心思想与源码分析》一书中的第3章,第3.6节创建任务调度器TaskScheduler,作者耿嘉安,更多章节内容可以访问云栖社区“华章社区”公众号查看
3.6 创建任务调度器TaskScheduler
TaskScheduler也是SparkContext的重要组成部分,负责任务的提交,并且请求集群管理器对任务调度。TaskScheduler也可以看做任务调度的客户端。创建TaskScheduler的代码如下。
private[spark] var (schedulerBackend, taskScheduler) =
SparkContext.createTaskScheduler(this, master)
createTaskScheduler方法会根据master的配置匹配部署模式