一、首先client会向master注册application,然后调用scschedule()开始启动Driver和Executor流程,分别向worker发送LaunchDriver和launchExecutor指令启动Driver和Executor。

Spark2.11 启动Driver以及Executor流程


Spark2.11 启动Driver以及Executor流程


Spark2.11 启动Driver以及Executor流程

二、Driver启动流程:worker通过DriverRunner启动线程的方式启动Driver

Spark2.11 启动Driver以及Executor流程

Spark2.11 启动Driver以及Executor流程


Spark2.11 启动Driver以及Executor流程


Spark2.11 启动Driver以及Executor流程

Spark2.11 启动Driver以及Executor流程

三、Executor的启动流程跟Driver 的启动流程差不多,略。


相关文章: