用户执行:
./bin/flink run -t yarn-per-job -c ... xx.jar
首先启动的进程是CliFronted,然后是YarnJobClusterEntryPoint进程,它是JobManager进程,最后是YarnTaskExecutorRunner(yarn模式)或者TakManagerRunner(standalone模式),它是TaskManager进程。
在上一篇文章《Flink内核源码解析系列(五):解析并通过执行用户的命令来执行用户jar中的main方法》以及前端四篇文章中,讲的都是启动CliFronted进程所做的事,我们再来回顾下,都做了哪几件事:
参数解析
封装CommandLine:三个,依次添加
配置的封装
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。