本文整理了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
[英]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);
}
内容来源于网络,如有侵权,请联系作者删除!