Home
last modified time | relevance | path

Searched refs:getMinSharePreemptionTimeout (Results 1 – 8 of 8) sorted by relevance

/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/
H A DTestAllocationFileLoaderService.java283 assertEquals(120000, queueConf.getMinSharePreemptionTimeout("root")); in testAllocationFileParsing()
284 assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root." + in testAllocationFileParsing()
286 assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueA")); in testAllocationFileParsing()
287 assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueB")); in testAllocationFileParsing()
288 assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueC")); in testAllocationFileParsing()
289 assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueD")); in testAllocationFileParsing()
291 assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueF")); in testAllocationFileParsing()
443 assertEquals(120000, queueConf.getMinSharePreemptionTimeout("root")); in testBackwardsCompatibleAllocationFileParsing()
444 assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root." + in testBackwardsCompatibleAllocationFileParsing()
446 assertEquals(-1, queueConf.getMinSharePreemptionTimeout("root.queueA")); in testBackwardsCompatibleAllocationFileParsing()
[all …]
H A DTestFairScheduler.java1979 .getMinSharePreemptionTimeout()); in testPreemptionDecisionWithVariousTimeout()
1981 .getMinSharePreemptionTimeout()); in testPreemptionDecisionWithVariousTimeout()
1983 .getMinSharePreemptionTimeout()); in testPreemptionDecisionWithVariousTimeout()
1985 .getMinSharePreemptionTimeout()); in testPreemptionDecisionWithVariousTimeout()
1987 .getMinSharePreemptionTimeout()); in testPreemptionDecisionWithVariousTimeout()
1989 .getMinSharePreemptionTimeout()); in testPreemptionDecisionWithVariousTimeout()
1991 .getMinSharePreemptionTimeout()); in testPreemptionDecisionWithVariousTimeout()
2145 .getMinSharePreemptionTimeout()); in testBackwardsCompatiblePreemptionConfiguration()
2147 .getMinSharePreemptionTimeout()); in testBackwardsCompatiblePreemptionConfiguration()
2149 .getMinSharePreemptionTimeout()); in testBackwardsCompatiblePreemptionConfiguration()
[all …]
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/
H A DFSQueue.java191 public long getMinSharePreemptionTimeout() { in getMinSharePreemptionTimeout() method in FSQueue
219 .getMinSharePreemptionTimeout(getName()); in updatePreemptionVariables()
221 minSharePreemptionTimeout = parent.getMinSharePreemptionTimeout(); in updatePreemptionVariables()
H A DAllocationConfiguration.java180 public long getMinSharePreemptionTimeout(String queueName) { in getMinSharePreemptionTimeout() method in AllocationConfiguration
H A DFairScheduler.java477 long minShareTimeout = sched.getMinSharePreemptionTimeout(); in resToPreempt()
/dports/devel/hadoop/hadoop-1.2.1/src/contrib/fairscheduler/src/test/org/apache/hadoop/mapred/
H A DTestFairScheduler.java707 assertEquals(120000, poolManager.getMinSharePreemptionTimeout( in testAllocationFileParsing()
709 assertEquals(120000, poolManager.getMinSharePreemptionTimeout("poolA")); in testAllocationFileParsing()
710 assertEquals(120000, poolManager.getMinSharePreemptionTimeout("poolB")); in testAllocationFileParsing()
711 assertEquals(120000, poolManager.getMinSharePreemptionTimeout("poolC")); in testAllocationFileParsing()
712 assertEquals(120000, poolManager.getMinSharePreemptionTimeout("poolD")); in testAllocationFileParsing()
713 assertEquals(120000, poolManager.getMinSharePreemptionTimeout("poolA")); in testAllocationFileParsing()
714 assertEquals(60000, poolManager.getMinSharePreemptionTimeout("poolE")); in testAllocationFileParsing()
/dports/devel/hadoop/hadoop-1.2.1/src/contrib/fairscheduler/src/java/org/apache/hadoop/mapred/
H A DFairScheduler.java634 long minShareTimeout = poolMgr.getMinSharePreemptionTimeout(pool.getName()); in getAllowedLocalityLevel()
987 long minShareTimeout = poolMgr.getMinSharePreemptionTimeout(pool); in tasksToPreempt()
H A DPoolManager.java529 public long getMinSharePreemptionTimeout(String pool) { in getMinSharePreemptionTimeout() method in PoolManager