Flink内核源码解析系列(六):通过YarnJobClusterEntryPoint类启动JobManager进程
2021/6/8 7:21:19
本文主要是介绍Flink内核源码解析系列(六):通过YarnJobClusterEntryPoint类启动JobManager进程,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
用户执行:
./bin/flink run -t yarn-per-job -c ... xx.jar
首先启动的进程是CliFronted,然后是YarnJobClusterEntryPoint进程,它是JobManager进程,最后是YarnTaskExecutorRunner(yarn模式)或者TakManagerRunner(standalone模式),它是TaskManager进程。
在上一篇文章《Flink内核源码解析系列(五):解析并通过执行用户的命令来执行用户jar中的main方法》以及前端四篇文章中,讲的都是启动CliFronted进程所做的事,我们再来回顾下,都做了哪几件事:
参数解析
封装CommandLine:三个,依次添加
配置的封装
这篇关于Flink内核源码解析系列(六):通过YarnJobClusterEntryPoint类启动JobManager进程的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-11-01UniApp 中组件的生命周期是多少-icode9专业技术文章分享
- 2024-11-01如何使用Svg Sprite Icon简化网页图标管理
- 2024-10-31Excel数据导出课程:新手从入门到精通的实用教程
- 2024-10-31Excel数据导入课程:新手入门指南
- 2024-10-31RBAC的权限课程:新手入门教程
- 2024-10-31Svg Sprite Icon课程:新手入门必备指南
- 2024-10-31怎么配置 L2TP 允许多用户连接-icode9专业技术文章分享
- 2024-10-31怎么在FreeBSD上 安装 OpenResty-icode9专业技术文章分享
- 2024-10-31运行 modprobe l2tp_ppp 时收到“module not found”消息提醒是什么-icode9专业技术文章分享
- 2024-10-31FreeBSD的下载命令有哪些-icode9专业技术文章分享