Spark-Job执行流程分析

在“Application启动流程分析”文章的第4步提到了，driver接收到Executor发送的RegisterExecutor消息以后，经过makeOffers()将任务随机分发给Executor。Executor（即CoarseGrainedExecutorBackend）收到后会将Task封装成TaskRunner对象，而后提交到Executor的线程池中去执行。Executor的线程池

>>阅读原文<<