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

QueueManager.removePendingIncompatibleQueues介绍

[英]Re-checking incompatible queues that could not be removed earlier due to not being empty, and removing those that became empty.
[中]重新检查由于不为空而无法提前删除的不兼容队列，并删除变为空的队列。

代码示例

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

@Override
 public void onCheck() {
  queueMgr.removeEmptyDynamicQueues();
  queueMgr.removePendingIncompatibleQueues();
 }
}

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

queueManager.removePendingIncompatibleQueues();
queueManager.removeEmptyDynamicQueues();
q = queueManager.getLeafQueue("root.a", false);
queueManager.removePendingIncompatibleQueues();
q = queueManager.getLeafQueue("root.a", false);
assertNotNull("root.a has been removed", q);
queueManager.removePendingIncompatibleQueues();
queueManager.removeEmptyDynamicQueues();
FSParentQueue p = queueManager.getParentQueue("root.a", false);

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

@Test
public void testRemovalOfChildlessParentQueue() {
 AllocationConfiguration allocConf = scheduler.getAllocationConfiguration();
 queueManager.updateAllocationConfiguration(allocConf);
 FSParentQueue q1 = queueManager.getParentQueue("root.test.childB", false);
 assertNotNull("Queue root.test.childB was not created", q1);
 assertEquals("createQueue() returned wrong queue",
   "root.test.childB", q1.getName());
 assertFalse("root.test.childB is a dynamic queue", q1.isDynamic());
 // static queues should not be deleted
 queueManager.removePendingIncompatibleQueues();
 queueManager.removeEmptyDynamicQueues();
 q1 = queueManager.getParentQueue("root.test.childB", false);
 assertNotNull("Queue root.test.childB was deleted", q1);
 // next we remove root.test.childB from the allocation config
 allocConf.configuredQueues.get(FSQueueType.PARENT)
   .remove("root.test.childB");
 queueManager.updateAllocationConfiguration(allocConf);
 queueManager.setQueuesToDynamic(Collections.singleton("root.test.childB"));
 // the next removeEmptyDynamicQueues() call should clean
 // root.test.childB up
 queueManager.removePendingIncompatibleQueues();
 queueManager.removeEmptyDynamicQueues();
 q1 = queueManager.getParentQueue("root.leaf1", false);
 assertNull("Queue root.leaf1 was not deleted", q1);
}

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

queueManager.removePendingIncompatibleQueues();
queueManager.removeEmptyDynamicQueues();
q1 = queueManager.getLeafQueue("root.leaf1", false);
queueManager.removePendingIncompatibleQueues();
queueManager.removeEmptyDynamicQueues();
q1 = queueManager.getLeafQueue("root.leaf1", false);

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

@Test
public void testRemovalOfDynamicLeafQueue() {
 AllocationConfiguration allocConf = scheduler.getAllocationConfiguration();
 queueManager.updateAllocationConfiguration(allocConf);
 FSQueue q1 = queueManager.getLeafQueue("root.test.childB.dynamic1", true);
 assertNotNull("Queue root.test.childB.dynamic1 was not created", q1);
 assertEquals("createQueue() returned wrong queue",
   "root.test.childB.dynamic1", q1.getName());
 assertTrue("root.test.childB.dynamic1 is not a dynamic queue",
   q1.isDynamic());
 // an application is submitted to root.test.childB.dynamic1
 notEmptyQueues.add(q1);
 // root.test.childB.dynamic1 is not empty and should not be removed
 queueManager.removePendingIncompatibleQueues();
 queueManager.removeEmptyDynamicQueues();
 q1 = queueManager.getLeafQueue("root.test.childB.dynamic1", false);
 assertNotNull("Queue root.test.childB.dynamic1 was deleted", q1);
 // the application finishes, the next removeEmptyDynamicQueues() should
 // clean root.test.childB.dynamic1 up, but keep its static parent
 notEmptyQueues.remove(q1);
 queueManager.removePendingIncompatibleQueues();
 queueManager.removeEmptyDynamicQueues();
 q1 = queueManager.getLeafQueue("root.test.childB.dynamic1", false);
 assertNull("Queue root.test.childB.dynamic1 was not deleted", q1);
 assertNotNull("The static parent of root.test.childB.dynamic1 was deleted",
   queueManager.getParentQueue("root.test.childB", false));
}

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

queueManager.removePendingIncompatibleQueues();
queueManager.removeEmptyDynamicQueues();
q1 = queueManager.getLeafQueue("root.test.childA", false);
queueManager.removePendingIncompatibleQueues();
queueManager.removeEmptyDynamicQueues();

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

assertFalse("root.leaf1 is empty", queueManager.isEmpty(q));
queueManager.removePendingIncompatibleQueues();
queueManager.removeEmptyDynamicQueues();
q = queueManager.getLeafQueue("root.leaf1", false);
queueManager.removePendingIncompatibleQueues();
queueManager.removeEmptyDynamicQueues();
q = queueManager.getLeafQueue("root.leaf1", false);

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

@Test
public void testRemovalOfDynamicParentQueue() {
 AllocationConfiguration allocConf = scheduler.getAllocationConfiguration();
 queueManager.updateAllocationConfiguration(allocConf);
 FSQueue q1 = queueManager.getLeafQueue("root.parent1.dynamic1", true);
 assertNotNull("Queue root.parent1.dynamic1 was not created", q1);
 assertEquals("createQueue() returned wrong queue",
   "root.parent1.dynamic1", q1.getName());
 assertTrue("root.parent1.dynamic1 is not a dynamic queue", q1.isDynamic());
 FSQueue p1 = queueManager.getParentQueue("root.parent1", false);
 assertNotNull("Queue root.parent1 was not created", p1);
 assertTrue("root.parent1 is not a dynamic queue", p1.isDynamic());
 queueManager.removePendingIncompatibleQueues();
 queueManager.removeEmptyDynamicQueues();
 q1 = queueManager.getLeafQueue("root.parent1.dynamic1", false);
 p1 = queueManager.getParentQueue("root.parent1", false);
 assertNull("Queue root.parent1.dynamic1 was not deleted", q1);
 assertNull("Queue root.parent1 was not deleted", p1);
}