Spark源码分析之Scheduler模块(TaskScheduler)

DAGScheduler将任务提交到TaskScheduler之后,接下来由TaskScheduler负责任务的调度。 TaskScheduler是一个trait(接口类),它的实现类是TaskSchedulerImpl。具体内容包括: 1、出现shuffle输出lost要报告fetch failed错误 2、碰到straggle任务需要放到别的节点上重试 3、为每个TaskSet维护一个Task
相关文章
相关标签/搜索