当前位置:网站首页>Spark On YARN的作业提交流程
Spark On YARN的作业提交流程
2022-07-26 22:40:00 【不会打球的摄影师不是好程序员】
1.Spark On YARN的主要进程:
1.SparkSubmit
2.ResourceManager
3.NodeManager
4.Executor
5.ApplicationMaster
2.执行流程
1.客户端想YARN的resourceManager提交应用程序
2.ResourceManager收到请求后,选择一个NodeManager节点向其分配一个Container,并在Container中启动ApplicationMaster,ApplicationMaster中包含SparkContext的初始化。
3.ApplicationMaster想ResourceManager申请Container。ResourceManager收到请求后,向ApplicationMaster分配Container。
4.ApplicationMaster请求NodeManager,NodeManager在获得的Container中启动Executor
5.Executor启动后,向ApplicationMaster的Driver中的SparkContext注册并申请Task
6.Executor在得到Task之后,开始执行Task,并向SparkContext汇报执行状态和进度等信息
边栏推荐
猜你喜欢

Leetcode 301 week

Vector size performance problems
![[CISCN2019 华北赛区 Day1 Web5]CyberPunk](/img/84/b186adc8becfc9b3def7dfd8e4cd41.png)
[CISCN2019 华北赛区 Day1 Web5]CyberPunk
![[红明谷CTF 2021]write_shell](/img/f5/c3a771ab7b40311e37a056defcbd78.png)
[红明谷CTF 2021]write_shell
![[ciscn2019 North China division Day1 web2]ikun](/img/80/53f8253a80a80931ff56f4e684839e.png)
[ciscn2019 North China division Day1 web2]ikun

Use of postman

14 web vulnerability: types of SQL injection and submission injection
![[WUSTCTF2020]CV Maker](/img/64/06023938e83acc832f06733b6c4d63.png)
[WUSTCTF2020]CV Maker
Alibaba internal "shutter" core advanced notes~

Parallel MPI program delivery send message
随机推荐
DOM day_01(7.7) dom的介绍和核心操作
SSRF explanation and burp automatic detection SSRF
[ciscn2019 North China division Day1 web2]ikun
el-checkbox中的checked勾选状态问题 2021-08-02
Solve the problem that there is no ado.net entity data model in vs
Canal introduction
flinksql 窗口提前触发
JSCORE day_03(7.4)
JSCORE day_ 01(6.30) RegExp 、 Function
[watevrCTF-2019]Cookie Store
重学JSON.stringify
2022.7.9DAY601
Programmers must do 50 questions
通过FlinkCDC将MySQL中变更的数据写入到kafka(DataStream方式)
5_ Linear regression
[4.1 prime number and linear sieve]
Detailed explanation of arrow function 2021-04-30
[WUSTCTF2020]CV Maker
Flink1.11 多并行度watermark测试
[CTF 真题] 2018-网鼎杯-Web-Unfinish