2
通知 Worker 启动 Executor
ClientEndpoint
7
3
SparkContext
伪分布式模式运行流程
启动应用程序，执行作业
发送任务到 Executor 进行执行
DAGScheduler
DriverEndpoint
Executor
1
运行节点
反馈任务执行状态
CoarseGrainedExecutorBacked
Task
SparkDeploySchedulerBackend
6
Master
TaskSchedulerImpl
应用程序运行完毕回收资源
Worker
MasterEndpoint
向 Master 注册应用程序
把 Executor 注册到 Driver
4
5
WorkerEndpoint
