Apache Flink源码分析---JobManager启动流程

Flink启动主要是启动JobManager进程和TaskManager进程，本章我们总结一下JobManager的启动流程：

JobManager启动流程：

启动类是org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint

配置JobManager启动：

JobManager入口：

public static void main(String[] args) {
		// startup checks and logging
		//提供对JVM执行环境的访问的实用程序类，如执行用户(getHadoopUser())、启动选项或JVM版本。
		EnvironmentInformation.logEnvironmentInfo(LOG, StandaloneSessionClusterEntrypoint.class.getSimpleName(), args);
		SignalHandler.register(LOG);
		JvmShutdownSafeguard.installAsShutdownHook(LOG);

		EntrypointClusterConfiguration entrypointClusterConfiguration = null;
		final CommandLinePa

本文地址：https://blog.csdn.net/wjandy0211/article/details/108854292