Spark-Job執行流程分析

在「Application啓動流程分析」文章的第4步提到了，driver接收到Executor發送的RegisterExecutor消息以後，經過makeOffers()將任務隨機分發給Executor。Executor（即CoarseGrainedExecutorBackend）收到後會將Task封裝成TaskRunner對象，而後提交到Executor的線程池中去執行。Executor的線程池

>>阅读原文<<