spark之(executor执行task原理分析)

 1>taskscheduler将taskset分发到对应的executor上thread 2>executor调用executor.launchtask方法方法 3>在launchtask方法中会建立taskrunner来封装这些任务,将这些taskruanner放入到threadpool中,封装 4>最终调用taskruanner方法中的task.runtask方法执行任务
相关文章
相关标签/搜索