本文整理了Java中org.apache.flink.yarn.YarnApplicationMasterRunner类的一些代码示例，展示了YarnApplicationMasterRunner类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。YarnApplicationMasterRunner类的具体详情如下：
包路径：org.apache.flink.yarn.YarnApplicationMasterRunner
类名称：YarnApplicationMasterRunner

YarnApplicationMasterRunner介绍

[英]This class is the executable entry point for the YARN application master. It starts actor system and the actors for JobManagerand YarnFlinkResourceManager.

The JobManager handles Flink job execution, while the YarnFlinkResourceManager handles container allocation and failure detection.
[中]此类是应用程序主控程序的可执行入口点。它启动actor系统和JobManager和YarnFlinkResourceManager的actor。
JobManager处理Flink作业执行，而YarnFlinkResourceManager处理容器分配和故障检测。

代码示例

代码示例来源：origin: apache/flink

/**
 * The entry point for the YARN application master.
 *
 * @param args The command line arguments.
 */
public static void main(String[] args) {
  EnvironmentInformation.logEnvironmentInfo(LOG, "YARN ApplicationMaster / ResourceManager / JobManager", args);
  SignalHandler.register(LOG);
  JvmShutdownSafeguard.installAsShutdownHook(LOG);
  // run and exit with the proper return code
  int returnCode = new YarnApplicationMasterRunner().run(args);
  System.exit(returnCode);
}

代码示例来源：origin: apache/flink

LOG.debug("YARN dynamic properties: {}", dynamicProperties);
final Configuration flinkConfig = createConfiguration(currDir, dynamicProperties, LOG);

代码示例来源：origin: apache/flink

@Override
  public Integer call() {
    return runApplicationMaster(flinkConfig);
  }
});

代码示例来源：origin: apache/flink

config, yarnConfig, ENV,
taskManagerParameters, taskManagerConfig,
currDir, getTaskManagerClass(), LOG);
new Some<>(JobMaster.JOB_MANAGER_NAME),
Option.<String>empty(),
getJobManagerClass(),
getArchivistClass())._1();
getResourceManagerClass(),
config,
yarnConfig,

代码示例来源：origin: org.apache.flink/flink-yarn_2.11

config, yarnConfig, ENV,
taskManagerParameters, taskManagerConfig,
currDir, getTaskManagerClass(), LOG);
new Some<>(JobMaster.JOB_MANAGER_NAME),
Option.<String>empty(),
getJobManagerClass(),
getArchivistClass())._1();
getResourceManagerClass(),
config,
yarnConfig,

代码示例来源：origin: org.apache.flink/flink-yarn

config, yarnConfig, ENV,
taskManagerParameters, taskManagerConfig,
currDir, getTaskManagerClass(), LOG);
new Some<>(JobMaster.JOB_MANAGER_NAME),
Option.<String>empty(),
getJobManagerClass(),
getArchivistClass())._1();
getResourceManagerClass(),
config,
yarnConfig,

代码示例来源：origin: org.apache.flink/flink-yarn_2.11

/**
 * The entry point for the YARN application master.
 *
 * @param args The command line arguments.
 */
public static void main(String[] args) {
  EnvironmentInformation.logEnvironmentInfo(LOG, "YARN ApplicationMaster / ResourceManager / JobManager", args);
  SignalHandler.register(LOG);
  JvmShutdownSafeguard.installAsShutdownHook(LOG);
  // run and exit with the proper return code
  int returnCode = new YarnApplicationMasterRunner().run(args);
  System.exit(returnCode);
}

代码示例来源：origin: org.apache.flink/flink-yarn

@Override
  public Integer call() {
    return runApplicationMaster(flinkConfig);
  }
});

代码示例来源：origin: org.apache.flink/flink-yarn

LOG.debug("YARN dynamic properties: {}", dynamicProperties);
final Configuration flinkConfig = createConfiguration(currDir, dynamicProperties, LOG);

代码示例来源：origin: org.apache.flink/flink-yarn

/**
 * The entry point for the YARN application master.
 *
 * @param args The command line arguments.
 */
public static void main(String[] args) {
  EnvironmentInformation.logEnvironmentInfo(LOG, "YARN ApplicationMaster / ResourceManager / JobManager", args);
  SignalHandler.register(LOG);
  JvmShutdownSafeguard.installAsShutdownHook(LOG);
  // run and exit with the proper return code
  int returnCode = new YarnApplicationMasterRunner().run(args);
  System.exit(returnCode);
}

代码示例来源：origin: org.apache.flink/flink-yarn_2.11

@Override
  public Integer call() {
    return runApplicationMaster(flinkConfig);
  }
});

代码示例来源：origin: org.apache.flink/flink-yarn_2.11

LOG.debug("YARN dynamic properties: {}", dynamicProperties);
final Configuration flinkConfig = createConfiguration(currDir, dynamicProperties, LOG);