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

 1>taskscheduler將taskset分發到對應的executor上thread 2>executor調用executor.launchtask方法方法 3>在launchtask方法中會建立taskrunner來封裝這些任務,將這些taskruanner放入到threadpool中,封裝 4>最終調用taskruanner方法中的task.runtask方法執行任務
相關文章
相關標籤/搜索