gpt4 book ai didi

org.apache.twill.yarn.YarnTwillRunnerService.setJVMOptions()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-15 11:42:40 25 4
gpt4 key购买 nike

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

YarnTwillRunnerService.setJVMOptions介绍

[英]This methods sets the extra JVM options that will be passed to the java command line for every application started through this YarnTwillRunnerService instance. It only affects applications that are started after options is set. This is intended for advance usage. All options will be passed unchanged to the java command line. Invalid options could cause application not able to start.
[中]这些方法设置了额外的JVM选项,这些选项将传递给通过YarnTwillRunnerService实例启动的每个应用程序的java命令行。它只影响设置选项后启动的应用程序。这是为了提前使用。所有选项都将原封不动地传递给java命令行。无效选项可能导致应用程序无法启动。

代码示例

代码示例来源:origin: co.cask.tigon/tigon-yarn

/**
  * Provider method for instantiating {@link org.apache.twill.yarn.YarnTwillRunnerService}.
  */
 @Singleton
 @Provides
 private YarnTwillRunnerService provideYarnTwillRunnerService(CConfiguration configuration,
                                YarnConfiguration yarnConfiguration,
                                LocationFactory locationFactory) {
  String zkConnectStr = configuration.get(Constants.Zookeeper.QUORUM) +
             configuration.get(Constants.CFG_TWILL_ZK_NAMESPACE);

  // Copy the yarn config and set the max heap ratio.
  YarnConfiguration yarnConfig = new YarnConfiguration(yarnConfiguration);
  yarnConfig.set(Constants.CFG_TWILL_RESERVED_MEMORY_MB, configuration.get(Constants.CFG_TWILL_RESERVED_MEMORY_MB));
  YarnTwillRunnerService runner = new YarnTwillRunnerService(yarnConfig,
                                zkConnectStr,
                                LocationFactories.namespace(locationFactory, "twill"));

  // Set JVM options based on configuration
  runner.setJVMOptions(configuration.get(Constants.Container.PROGRAM_JVM_OPTS));

  return runner;
 }
}

代码示例来源:origin: apache/twill

/**
 * Creates an unstarted instance of {@link org.apache.twill.api.TwillRunnerService}.
 */
public TwillRunnerService createTwillRunnerService() throws IOException {
 YarnTwillRunnerService runner = new YarnTwillRunnerService(config, zkServer.getConnectionStr() + "/twill",
                               createLocationFactory());
 // disable tests stealing focus
 runner.setJVMOptions("-Djava.awt.headless=true");
 return runner;
}

代码示例来源:origin: co.cask.cdap/cdap-app-fabric

@Override
 public TwillRunnerService get() {
  String zkConnectStr = cConf.get(Constants.Zookeeper.QUORUM) + cConf.get(Constants.CFG_TWILL_ZK_NAMESPACE);
  // Copy the yarn config and setup twill configs
  YarnConfiguration yarnConfig = new YarnConfiguration(yarnConf);
  // Always disable the location delegation update from twill, as we always do it from CDAP side
  yarnConfig.setBoolean(Configs.Keys.SECURE_STORE_UPDATE_LOCATION_ENABLED, false);
  YarnTwillRunnerService runner = new YarnTwillRunnerService(yarnConfig,
                                zkConnectStr,
                                LocationFactories.namespace(locationFactory, "twill"));
  // Set JVM options based on configuration
  String jvmOpts = cConf.get(Constants.AppFabric.PROGRAM_JVM_OPTS);
  runner.setJVMOptions(jvmOpts);
  return new ImpersonatedTwillRunnerService(yarnConf, runner, impersonator, secureStoreRenewer);
 }
}

代码示例来源:origin: cdapio/cdap

@Override
 public TwillRunnerService get() {
  String zkConnectStr = cConf.get(Constants.Zookeeper.QUORUM) + cConf.get(Constants.CFG_TWILL_ZK_NAMESPACE);
  // Copy the yarn config and setup twill configs
  YarnConfiguration yarnConfig = new YarnConfiguration(yarnConf);
  // Always disable the location delegation update from twill, as we always do it from CDAP side
  yarnConfig.setBoolean(Configs.Keys.SECURE_STORE_UPDATE_LOCATION_ENABLED, false);
  YarnTwillRunnerService runner = new YarnTwillRunnerService(yarnConfig,
                                zkConnectStr,
                                LocationFactories.namespace(locationFactory, "twill"));
  // Set JVM options based on configuration
  String jvmOpts = cConf.get(Constants.AppFabric.PROGRAM_JVM_OPTS);
  runner.setJVMOptions(jvmOpts);
  return new ImpersonatedTwillRunnerService(yarnConf, runner, impersonator, secureStoreRenewer);
 }
}

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com