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

AllocationConfiguration.getMinSharePreemptionTimeout介绍

[英]Get a queue's min share preemption timeout configured in the allocation file, in milliseconds. Return -1 if not set.
[中]获取在分配文件中配置的队列的最小共享抢占超时，以毫秒为单位。如果未设置，则返回-1。

代码示例

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

/**
 * Update the min/fair share preemption timeouts and threshold for this queue.
 */
public void updatePreemptionVariables() {
 // For min share timeout
 minSharePreemptionTimeout = scheduler.getAllocationConfiguration()
   .getMinSharePreemptionTimeout(getName());
 if (minSharePreemptionTimeout == -1 && parent != null) {
  minSharePreemptionTimeout = parent.getMinSharePreemptionTimeout();
 }
 // For fair share timeout
 fairSharePreemptionTimeout = scheduler.getAllocationConfiguration()
   .getFairSharePreemptionTimeout(getName());
 if (fairSharePreemptionTimeout == -1 && parent != null) {
  fairSharePreemptionTimeout = parent.getFairSharePreemptionTimeout();
 }
 // For fair share preemption threshold
 fairSharePreemptionThreshold = scheduler.getAllocationConfiguration()
   .getFairSharePreemptionThreshold(getName());
 if (fairSharePreemptionThreshold < 0 && parent != null) {
  fairSharePreemptionThreshold = parent.getFairSharePreemptionThreshold();
 }
}

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

/**
 * Update the min/fair share preemption timeouts and threshold for this queue.
 */
public void updatePreemptionVariables() {
 // For min share timeout
 minSharePreemptionTimeout = scheduler.getAllocationConfiguration()
   .getMinSharePreemptionTimeout(getName());
 if (minSharePreemptionTimeout == -1 && parent != null) {
  minSharePreemptionTimeout = parent.getMinSharePreemptionTimeout();
 }
 // For fair share timeout
 fairSharePreemptionTimeout = scheduler.getAllocationConfiguration()
   .getFairSharePreemptionTimeout(getName());
 if (fairSharePreemptionTimeout == -1 && parent != null) {
  fairSharePreemptionTimeout = parent.getFairSharePreemptionTimeout();
 }
 // For fair share preemption threshold
 fairSharePreemptionThreshold = scheduler.getAllocationConfiguration()
   .getFairSharePreemptionThreshold(getName());
 if (fairSharePreemptionThreshold < 0 && parent != null) {
  fairSharePreemptionThreshold = parent.getFairSharePreemptionThreshold();
 }
}

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

assertEquals(5, queueConf.getUserMaxApps("user2"));
assertEquals(120000, queueConf.getMinSharePreemptionTimeout("root"));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root." +
  YarnConfiguration.DEFAULT_QUEUE_NAME));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueA"));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueB"));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueC"));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueD"));
assertEquals(60000, queueConf.getMinSharePreemptionTimeout("root.queueE"));

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

QueueACL.SUBMIT_APPLICATIONS).getAclString());
assertEquals(120000, queueConf.getMinSharePreemptionTimeout("root"));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root." +
  YarnConfiguration.DEFAULT_QUEUE_NAME));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueA"));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueB"));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueC"));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueD"));
assertEquals(60000, queueConf.getMinSharePreemptionTimeout("root.queueE"));

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

.getMinSharePreemptionTimeout(getName());
if (minSharePreemptionTimeout == -1 && parent != null) {
 minSharePreemptionTimeout = parent.getMinSharePreemptionTimeout();

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

QueueACL.SUBMIT_APPLICATIONS).getAclString());
assertEquals(120000, queueConf.getMinSharePreemptionTimeout("root"));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root." +
  YarnConfiguration.DEFAULT_QUEUE_NAME));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueA"));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueB"));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueC"));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueD"));
assertEquals(60000, queueConf.getMinSharePreemptionTimeout("root.queueE"));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueF"));
assertEquals(50000, queueConf.getMinSharePreemptionTimeout("root.queueG"));
assertEquals(40000, queueConf.getMinSharePreemptionTimeout("root.queueG.queueH"));

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

queueConf.getQueueMaxContainerAllocation("root.queueG.queueH"));
assertEquals(120000, queueConf.getMinSharePreemptionTimeout("root"));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root." +
  YarnConfiguration.DEFAULT_QUEUE_NAME));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueA"));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueB"));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueC"));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueD"));
assertEquals(60000, queueConf.getMinSharePreemptionTimeout("root.queueE"));
assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueF"));
assertEquals(50000, queueConf.getMinSharePreemptionTimeout("root.queueG"));
assertEquals(40000, queueConf.getMinSharePreemptionTimeout("root.queueG.queueH"));