首页 热点资讯 义务教育 高等教育 出国留学 考研考公
您的当前位置:首页正文

==[图]Spark系列(四)整体架构分析

2024-12-20 来源:化拓教育网
Paste_Image.png

说明

Driver端流程说明(Standalone模式)

使用spark-submit提交Spark应用程序Application.

通过反射的方式创建和构造一个DriverActor进程(Driver进程).

SparkContext初始化,构造DAGScheduler和TaskScheduler.

每执行到一个Action操作就会创建一个job,该job会提交到DAGScheduler,划分为多个stage然后为每个stage创建一个TaskSet.

TaskScheduler负责连接Master并向Master注册Application.

TaskScheduler把TaskSet中的每一个task提交到executor上执行(task分配算法).

SparkContext的初始化在所有Executor完成反向注册后才完成,并继续执行提交的应用程序.

Master和Worker流程说明

Master接收到Application注册请求后会使用自己的资源调度算法,在Spark集群的Work上为这个Application启动多个Executor.

Executor启动之后反注册到TaskScheduler.

Executor每次收到一个task都会用TaskRunner来封装task,然后从线程池里取出一个线程执行这个task.

TaskRunner将需执行的算子及函数、拷贝、反序列化然后执行task.

显示全文