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

QueueMetrics.runAppAttempt介绍

暂无

代码示例

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

public void runAppAttempt(ApplicationId appId, String user) {
 runBuckets.add(appId, System.currentTimeMillis());
 appsRunning.incr();
 appsPending.decr();
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.runAppAttempt(appId, user);
 }
 if (parent != null) {
  parent.runAppAttempt(appId, user);
 }
}

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

public void runAppAttempt(ApplicationId appId, String user) {
 runBuckets.add(appId, System.currentTimeMillis());
 appsRunning.incr();
 appsPending.decr();
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.runAppAttempt(appId, user);
 }
 if (parent != null) {
  parent.runAppAttempt(appId, user);
 }
}

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

public void runAppAttempt(ApplicationId appId, String user) {
 runBuckets.add(appId, System.currentTimeMillis());
 appsRunning.incr();
 appsPending.decr();
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.runAppAttempt(appId, user);
 }
 if (parent != null) {
  parent.runAppAttempt(appId, user);
 }
}

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

private void updateMetricsForAllocatedContainer(NodeType type,
  SchedulerNode node, Container containerAllocated) {
 QueueMetrics metrics = queue.getMetrics();
 if (pending) {
  // once an allocation is done we assume the application is
  // running from scheduler's POV.
  pending = false;
  metrics.runAppAttempt(applicationId, user);
 }
 updateMetrics(applicationId, type, node, containerAllocated, user, queue);
}

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

public void recoverContainer(RMContainer rmContainer, String partition) {
 if (rmContainer.getExecutionType() != ExecutionType.GUARANTEED) {
  return;
 }
 try {
  this.writeLock.lock();
  QueueMetrics metrics = queue.getMetrics();
  if (pending) {
   // If there was any container to recover, the application was
   // running from scheduler's POV.
   pending = false;
   metrics.runAppAttempt(applicationId, user);
  }
  // Container is completed. Skip recovering resources.
  if (rmContainer.getState().equals(RMContainerState.COMPLETED)) {
   return;
  }
  metrics.allocateResources(partition, user, 1,
    rmContainer.getAllocatedResource(), false);
 } finally {
  this.writeLock.unlock();
 }
}

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

public synchronized void recoverContainer(RMContainer rmContainer) {
 QueueMetrics metrics = queue.getMetrics();
 if (pending) {
  // If there was any container to recover, the application was
  // running from scheduler's POV.
  pending = false;
  metrics.runAppAttempt(applicationId, user);
 }
 // Container is completed. Skip recovering resources.
 if (rmContainer.getState().equals(RMContainerState.COMPLETED)) {
  return;
 }
 metrics.allocateResources(user, 1, rmContainer.getAllocatedResource(),
  false);
}

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

public synchronized void recoverContainer(RMContainer rmContainer) {
 QueueMetrics metrics = queue.getMetrics();
 if (pending) {
  // If there was any container to recover, the application was
  // running from scheduler's POV.
  pending = false;
  metrics.runAppAttempt(applicationId, user);
 }
 // Container is completed. Skip recovering resources.
 if (rmContainer.getState().equals(RMContainerState.COMPLETED)) {
  return;
 }
 metrics.allocateResources(user, 1, rmContainer.getAllocatedResource(),
  false);
}

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

metrics.runAppAttempt(applicationId, user);

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

metrics.runAppAttempt(applicationId, user);

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

checkApps(queueSource, 1, 1, 0, 0, 0, 0, true);
metrics.runAppAttempt(app.getApplicationId(), user);
checkApps(queueSource, 1, 0, 1, 0, 0, 0, true);
checkApps(queueSource, 1, 1, 0, 0, 0, 0, true);
metrics.runAppAttempt(app.getApplicationId(), user);
checkApps(queueSource, 1, 0, 1, 0, 0, 0, true);
checkApps(queueSource, 1, 1, 0, 0, 0, 0, true);
metrics.runAppAttempt(app.getApplicationId(), user);
checkApps(queueSource, 1, 0, 1, 0, 0, 0, true);

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

checkApps(queueSource, 1, 1, 0, 0, 0, 0, true);
metrics.runAppAttempt(app.getApplicationId(), user);
checkApps(queueSource, 1, 0, 1, 0, 0, 0, true);
checkApps(queueSource, 1, 1, 0, 0, 0, 0, true);
metrics.runAppAttempt(app.getApplicationId(), user);
checkApps(queueSource, 1, 0, 1, 0, 0, 0, true);
checkApps(queueSource, 1, 1, 0, 0, 0, 0, true);
metrics.runAppAttempt(app.getApplicationId(), user);
checkApps(queueSource, 1, 0, 1, 0, 0, 0, true);

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

metrics.runAppAttempt(app.getApplicationId(), user);
checkApps(queueSource, 1, 0, 1, 0, 0, 0, true);

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

checkResources(parentUserSource, 0, 0, 0, 0, 0, 10*GB, 10, 15*GB, 15, 5, 0, 0, 0);
metrics.runAppAttempt(app.getApplicationId(), user);
checkApps(queueSource, 1, 0, 1, 0, 0, 0, true);
checkApps(userSource, 1, 0, 1, 0, 0, 0, true);

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

metrics.runAppAttempt(app.getApplicationId(), user);
checkApps(queueSource, 1, 0, 1, 0, 0, 0, true);

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

checkResources(userSource, 0, 0, 0, 0, 0, 10*GB, 10, 15*GB, 15, 5, 0, 0, 0);
metrics.runAppAttempt(app.getApplicationId(), user);
checkApps(queueSource, 1, 0, 1, 0, 0, 0, true);
checkApps(userSource, 1, 0, 1, 0, 0, 0, true);

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

checkResources(userSource, 0, 0, 0, 0, 0, 10*GB, 10, 15*GB, 15, 5, 0, 0, 0);
metrics.runAppAttempt(app.getApplicationId(), user);
checkApps(queueSource, 1, 0, 1, 0, 0, 0, true);
checkApps(userSource, 1, 0, 1, 0, 0, 0, true);

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

checkResources(parentUserSource, 0, 0, 0, 0, 0, 10*GB, 10, 15*GB, 15, 5, 0, 0, 0);
metrics.runAppAttempt(app.getApplicationId(), user);
checkApps(queueSource, 1, 0, 1, 0, 0, 0, true);
checkApps(userSource, 1, 0, 1, 0, 0, 0, true);