一、首先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 的启动流程差不多,略。


相关文章:

  • 2021-04-15
  • 2021-09-02
  • 2021-05-13
  • 2021-07-06
  • 2022-01-15
  • 2021-09-01
  • 2021-06-18
  • 2021-07-16
猜你喜欢
  • 2021-12-29
  • 2021-10-20
  • 2021-04-02
  • 2022-12-23
  • 2021-12-10
  • 2022-01-20
  • 2021-07-31
相关资源
相似解决方案