Spark 任务执行流程?
Spark 执行流程详解。
SparkContext
向资源管理器注册并申请运行Executor
,资源管理器分配并启动Executor
Executor
发送心跳至资源管理器,保持通信SparkContext
构建DAG
有向无环图,将DAG
分解成 Stage,把Stage
发送给TaskScheduler
Executor
向SparkContext
申请Task
,TaskScheduler
将Task
和应用程序代码发送给Executor
运行Task
在Executor
上运行,运行完毕把结果反馈给Driver
端,释放所有资源
参考链接