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

NodeManager.getConfig介绍

暂无

代码示例

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

private int verifyContainerLog(int containerNum,
                List<String> expectedContent, boolean count, String expectedWord) {
 File logFolder =
     new File(yarnComponent.getYARNCluster().getNodeManager(0).getConfig()
         .get(YarnConfiguration.NM_LOG_DIRS,
             YarnConfiguration.DEFAULT_NM_LOG_DIRS));

代码示例来源：origin: io.hops/hadoop-yarn-server-nodemanager

protected NMContext createNMContext(
  NMContainerTokenSecretManager containerTokenSecretManager,
  NMTokenSecretManagerInNM nmTokenSecretManager,
  NMStateStoreService stateStore) {
 boolean isSSLEnabled = getConfig().getBoolean
   (CommonConfigurationKeysPublic.IPC_SERVER_SSL_ENABLED,
     CommonConfigurationKeysPublic.IPC_SERVER_SSL_ENABLED_DEFAULT);
 return new NMContext(containerTokenSecretManager, nmTokenSecretManager,
   dirsHandler, aclsManager, stateStore, isSSLEnabled);
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-nodemanager

protected void doSecureLogin() throws IOException {
 SecurityUtil.login(getConfig(), YarnConfiguration.NM_KEYTAB,
   YarnConfiguration.NM_PRINCIPAL);
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-nodemanager

protected void doSecureLogin() throws IOException {
 SecurityUtil.login(getConfig(), YarnConfiguration.NM_KEYTAB,
   YarnConfiguration.NM_PRINCIPAL);
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-nodemanager

protected void doSecureLogin() throws IOException {
 SecurityUtil.login(getConfig(), YarnConfiguration.NM_KEYTAB,
   YarnConfiguration.NM_PRINCIPAL);
}

代码示例来源：origin: io.hops/hadoop-yarn-server-nodemanager

protected void doSecureLogin() throws IOException {
 SecurityUtil.login(getConfig(), YarnConfiguration.NM_KEYTAB,
   YarnConfiguration.NM_PRINCIPAL);
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-nodemanager

private void stopRecoveryStore() throws IOException {
 if (null != nmStore) {
  nmStore.stop();
  if (null != context) {
   if (context.getDecommissioned() && nmStore.canRecover()) {
    LOG.info("Removing state store due to decommission");
    Configuration conf = getConfig();
    Path recoveryRoot =
      new Path(conf.get(YarnConfiguration.NM_RECOVERY_DIR));
    LOG.info("Removing state store at " + recoveryRoot
      + " due to decommission");
    FileSystem recoveryFs = FileSystem.getLocal(conf);
    if (!recoveryFs.delete(recoveryRoot, true)) {
     LOG.warn("Unable to delete " + recoveryRoot);
    }
   }
  }
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-nodemanager

private void stopRecoveryStore() throws IOException {
 if (null != nmStore) {
  nmStore.stop();
  if (null != context) {
   if (context.getDecommissioned() && nmStore.canRecover()) {
    LOG.info("Removing state store due to decommission");
    Configuration conf = getConfig();
    Path recoveryRoot =
      new Path(conf.get(YarnConfiguration.NM_RECOVERY_DIR));
    LOG.info("Removing state store at " + recoveryRoot
      + " due to decommission");
    FileSystem recoveryFs = FileSystem.getLocal(conf);
    if (!recoveryFs.delete(recoveryRoot, true)) {
     LOG.warn("Unable to delete " + recoveryRoot);
    }
   }
  }
 }
}

代码示例来源：origin: io.hops/hadoop-yarn-server-nodemanager

private void stopRecoveryStore() throws IOException {
 if (null != nmStore) {
  nmStore.stop();
  if (null != context) {
   if (context.getDecommissioned() && nmStore.canRecover()) {
    LOG.info("Removing state store due to decommission");
    Configuration conf = getConfig();
    Path recoveryRoot =
      new Path(conf.get(YarnConfiguration.NM_RECOVERY_DIR));
    LOG.info("Removing state store at " + recoveryRoot
      + " due to decommission");
    FileSystem recoveryFs = FileSystem.getLocal(conf);
    if (!recoveryFs.delete(recoveryRoot, true)) {
     LOG.warn("Unable to delete " + recoveryRoot);
    }
   }
  }
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-nodemanager

private void stopRecoveryStore() throws IOException {
 if (null != nmStore) {
  nmStore.stop();
  if (null != context) {
   if (context.getDecommissioned() && nmStore.canRecover()) {
    LOG.info("Removing state store due to decommission");
    Configuration conf = getConfig();
    Path recoveryRoot =
      new Path(conf.get(YarnConfiguration.NM_RECOVERY_DIR));
    LOG.info("Removing state store at " + recoveryRoot
      + " due to decommission");
    FileSystem recoveryFs = FileSystem.getLocal(conf);
    if (!recoveryFs.delete(recoveryRoot, true)) {
     LOG.warn("Unable to delete " + recoveryRoot);
    }
   }
  }
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-mapreduce-client-jobclient

final Configuration nmConf = mrCluster.getNodeManager(0).getConfig();

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-tests

+ nm.getConfig().get(dirsProperty));
dirsHandler = nm.getNodeHealthChecker().getDiskHandler();
List<String> list = localORLogDirs ? dirsHandler.getLocalDirs()

代码示例来源：origin: ch.cern.hadoop/hadoop-mapreduce-client-jobclient

final Configuration nmConf = mrCluster.getNodeManager(i).getConfig();
for (String logDir :
     nmConf.getTrimmedStrings(YarnConfiguration.NM_LOG_DIRS)) {

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-tests

+ nm.getConfig().get(dirsProperty));
dirsHandler = nm.getNodeHealthChecker().getDiskHandler();
List<String> list = localORLogDirs ? dirsHandler.getLocalDirs()