org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.QueueManager.removeEmptyIncompatibleQueues()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(3.1k)|赞(0)|评价(0)|浏览(102)

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

QueueManager.removeEmptyIncompatibleQueues介绍

[英]Make way for the given queue if possible, by removing incompatible queues with no apps in them. Incompatibility could be due to (1) queueToCreate being currently a parent but needs to change to leaf (2) queueToCreate being currently a leaf but needs to change to parent (3) an existing leaf queue in the ancestry of queueToCreate. We will never remove the root queue or the default queue in this way.
[中]如果可能的话,为给定的队列让路,方法是删除不兼容的队列,这些队列中没有应用程序。不兼容可能是由于(1)queueToCreate当前为父级,但需要更改为叶级(2)queueToCreate当前为叶级,但需要更改为父级(3)queueToCreate祖先中的现有叶级队列。我们永远不会以这种方式删除根队列或默认队列。

代码示例

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

/**
 * Remove a leaf queue if empty
 * @param name name of the queue
 * @return true if queue was removed or false otherwise
 */
public boolean removeLeafQueue(String name) {
 name = ensureRootPrefix(name);
 return removeEmptyIncompatibleQueues(name, FSQueueType.PARENT);
}

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

/**
 * Remove a leaf queue if empty
 * @param name name of the queue
 * @return true if queue was removed or false otherwise
 */
public boolean removeLeafQueue(String name) {
 name = ensureRootPrefix(name);
 return removeEmptyIncompatibleQueues(name, FSQueueType.PARENT);
}

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

/**
 * Remove a leaf queue if empty.
 * @param name name of the queue
 * @return true if queue was removed or false otherwise
 */
public boolean removeLeafQueue(String name) {
 name = ensureRootPrefix(name);
 return !Boolean.FALSE.equals(
   removeEmptyIncompatibleQueues(name, FSQueueType.PARENT).orElse(null));
}

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

private void ensureQueueExistsAndIsCompatibleAndIsStatic(
  AllocationConfiguration queueConf, FSQueueType queueType) {
 for (String name : queueConf.getConfiguredQueues().get(queueType)) {
  Boolean removed =
    removeEmptyIncompatibleQueues(name, queueType).orElse(null);
  if (Boolean.FALSE.equals(removed)) {
   incompatibleQueuesPendingRemoval.add(
     new IncompatibleQueueRemovalTask(name, queueType));
  } else {
   FSQueue queue = getQueue(name, true, queueType, false, null);
   if (queue != null) {
    queue.setDynamic(false);
   }
  }
 }
}

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

public void updateAllocationConfiguration(AllocationConfiguration queueConf) {
  if (removeEmptyIncompatibleQueues(name, FSQueueType.LEAF)) {
   getLeafQueue(name, true);
  if (removeEmptyIncompatibleQueues(name, FSQueueType.PARENT)) {
   getParentQueue(name, true);

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

public void updateAllocationConfiguration(AllocationConfiguration queueConf) {
  if (removeEmptyIncompatibleQueues(name, FSQueueType.LEAF)) {
   getLeafQueue(name, true);
  if (removeEmptyIncompatibleQueues(name, FSQueueType.PARENT)) {
   getParentQueue(name, true);

相关文章