上一篇: task生成.
Task生成后回被包装成TaskSetManager,然后放入任务调度器中的任务池中并根据调度算法进行排序,任务调度器有先进先出调度器和公平调度器。之后发往Executor,在其中线程池中执行Task的override def runTask(context: TaskContext): MapStatus函数。

Task生成后回被包装成TaskSetManager,然后放入任务调度器中的任务池中并根据调度算法进行排序,任务调度器有先进先出调度器和公平调度器。之后发往Executor,在其中线程池中执行Task的override def runTask(context: TaskContext): MapStatus函数。