我要评论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
您可能感兴趣的文章:
如您对本文有疑问或者有任何想说的，请点击进行留言回复，万千网友为您解惑！
网友评论