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

YarnScheduler.getRMContainer介绍

[英]Get the container for the given containerId.
[中]获取给定容器ID的容器。

代码示例

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

RMContainer container = scheduler.getRMContainer(containerId);
if (container != null) {
 this.rmContext.getDispatcher().getEventHandler().handle(

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

thenReturn(allocation);
RMContainer rmContainer = mock(RMContainerImpl.class);
when(scheduler.getRMContainer(container.getId())).
  thenReturn(rmContainer);

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

.get(0));
RMContainerImpl rmMasterContainer = (RMContainerImpl)appAttempt.scheduler
  .getRMContainer(appAttempt.getMasterContainer().getId());
rmMasterContainer.setAMContainer(true);

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

.get(0));
RMContainerImpl rmMasterContainer = (RMContainerImpl)appAttempt.scheduler
  .getRMContainer(appAttempt.getMasterContainer().getId());
rmMasterContainer.setAMContainer(true);

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

.get(0));
RMContainerImpl rmMasterContainer = (RMContainerImpl)appAttempt.scheduler
  .getRMContainer(appAttempt.getMasterContainer().getId());
rmMasterContainer.setAMContainer(true);

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

thenReturn(allocation);
RMContainer rmContainer = mock(RMContainerImpl.class);
when(scheduler.getRMContainer(container.getId())).
  thenReturn(rmContainer);

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

.thenReturn(allocation);
RMContainer rmContainer = mock(RMContainerImpl.class);
when(scheduler.getRMContainer(amContainer.getId())).thenReturn(rmContainer);

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

any(List.class), any(List.class), any(List.class))).thenReturn(allocation);
RMContainer rmContainer = mock(RMContainerImpl.class);
when(scheduler.getRMContainer(amContainer.getId())).thenReturn(rmContainer);

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

containerReports.add(containerReport);
scheduler.handle(new NodeAddedSchedulerEvent(node1, containerReports));
RMContainer rmContainer = scheduler.getRMContainer(containerId);

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

assertNull(scheduler.getRMContainer(runningContainer.getContainerId()));
assertNull(scheduler.getRMContainer(completedContainer.getContainerId()));
assertNull(scheduler.getRMContainer(previousAttemptContainer.getContainerId()));

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

assertNull(scheduler.getRMContainer(runningContainer.getContainerId()));
assertNull(scheduler.getRMContainer(completedContainer.getContainerId()));

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

@Test (timeout = 30000)
public void testAMContainerStatusWithRMRestart() throws Exception {  
 rm1 = new MockRM(conf);
 rm1.start();
 MockNM nm1 =
   new MockNM("127.0.0.1:1234", 8192, rm1.getResourceTrackerService());
 nm1.registerNode();
 RMApp app1_1 = rm1.submitApp(1024);
 MockAM am1_1 = MockRM.launchAndRegisterAM(app1_1, rm1, nm1);
 
 RMAppAttempt attempt0 = app1_1.getCurrentAppAttempt();
 YarnScheduler scheduler = rm1.getResourceScheduler();
 Assert.assertTrue(scheduler.getRMContainer(
   attempt0.getMasterContainer().getId()).isAMContainer());
 // Re-start RM
 rm2 = new MockRM(conf, rm1.getRMStateStore());
 rm2.start();
 nm1.setResourceTrackerService(rm2.getResourceTrackerService());
 List<NMContainerStatus> am1_1Containers =
   createNMContainerStatusForApp(am1_1);
 nm1.registerNode(am1_1Containers, null);
 // Wait for RM to settle down on recovering containers;
 waitForNumContainersToRecover(2, rm2, am1_1.getApplicationAttemptId());
 scheduler = rm2.getResourceScheduler();
 Assert.assertTrue(scheduler.getRMContainer(
   attempt0.getMasterContainer().getId()).isAMContainer());
}