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

ZKRMStateStore.loadApplicationAttemptState介绍

暂无

代码示例

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

private void loadRMAppStateFromAppNode(RMState rmState, String appNodePath,
  String appIdStr) throws Exception {
 byte[] appData = getData(appNodePath);
 if (LOG.isDebugEnabled()) {
  LOG.debug("Loading application from znode: " + appNodePath);
 }
 ApplicationId appId = ApplicationId.fromString(appIdStr);
 ApplicationStateDataPBImpl appState = new ApplicationStateDataPBImpl(
   ApplicationStateDataProto.parseFrom(appData));
 if (!appId.equals(
   appState.getApplicationSubmissionContext().getApplicationId())) {
  throw new YarnRuntimeException("The node name is different from the " +
      "application id");
 }
 rmState.appState.put(appId, appState);
 loadApplicationAttemptState(appState, appNodePath);
}

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

private synchronized void loadRMAppState(RMState rmState) throws Exception {
 List<String> childNodes = getChildrenWithRetries(rmAppRoot, false);
 for (String childNodeName : childNodes) {
  String childNodePath = getNodePath(rmAppRoot, childNodeName);
  byte[] childData = getDataWithRetries(childNodePath, false);
  if (childNodeName.startsWith(ApplicationId.appIdStrPrefix)) {
   // application
   if (LOG.isDebugEnabled()) {
    LOG.debug("Loading application from znode: " + childNodeName);
   }
   ApplicationId appId = ConverterUtils.toApplicationId(childNodeName);
   ApplicationStateDataPBImpl appState =
     new ApplicationStateDataPBImpl(
       ApplicationStateDataProto.parseFrom(childData));
   if (!appId.equals(
     appState.getApplicationSubmissionContext().getApplicationId())) {
    throw new YarnRuntimeException("The child node name is different " +
      "from the application id");
   }
   rmState.appState.put(appId, appState);
   loadApplicationAttemptState(appState, appId);
  } else {
   LOG.info("Unknown child node with name: " + childNodeName);
  }
 }
}

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

private synchronized void loadRMAppState(RMState rmState) throws Exception {
 List<String> childNodes = getChildrenWithRetries(rmAppRoot, false);
 for (String childNodeName : childNodes) {
  String childNodePath = getNodePath(rmAppRoot, childNodeName);
  byte[] childData = getDataWithRetries(childNodePath, false);
  if (childNodeName.startsWith(ApplicationId.appIdStrPrefix)) {
   // application
   if (LOG.isDebugEnabled()) {
    LOG.debug("Loading application from znode: " + childNodeName);
   }
   ApplicationId appId = ConverterUtils.toApplicationId(childNodeName);
   ApplicationStateDataPBImpl appState =
     new ApplicationStateDataPBImpl(
       ApplicationStateDataProto.parseFrom(childData));
   if (!appId.equals(
     appState.getApplicationSubmissionContext().getApplicationId())) {
    throw new YarnRuntimeException("The child node name is different " +
      "from the application id");
   }
   rmState.appState.put(appId, appState);
   loadApplicationAttemptState(appState, appId);
  } else {
   LOG.info("Unknown child node with name: " + childNodeName);
  }
 }
}