系统相关
首页 > 系统相关> > Flink内核源码解析系列(六):通过YarnJobClusterEntryPoint类启动JobManager进程

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:三个,依次添加
配置的封装

标签:YarnJobClusterEntryPoint,Flink,JobManager,源码,进程,解析
来源: https://blog.csdn.net/MissWYAN/article/details/117676654