Spark TaskScheduler的源码图解

TaskScheduler模块用于与DAGScheduler交互,负责任务的具体调度和运行。任务调度模块基于两个Trait:TaskScheduler和 SchedulerBackend。 TaskScheduler:定义了任务调度模块的对外接口(submitTasks等),供DAGScheduler调用。 TaskSchedulerImpl是TaskScheduler的具体实现,完成资源与任务的
相关文章
相关标签/搜索