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 D | TestAllocationFileLoaderService.java | 283 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 D | TestFairScheduler.java | 1979 .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 D | FSQueue.java | 191 public long getMinSharePreemptionTimeout() { in getMinSharePreemptionTimeout() method in FSQueue 219 .getMinSharePreemptionTimeout(getName()); in updatePreemptionVariables() 221 minSharePreemptionTimeout = parent.getMinSharePreemptionTimeout(); in updatePreemptionVariables()
|
H A D | AllocationConfiguration.java | 180 public long getMinSharePreemptionTimeout(String queueName) { in getMinSharePreemptionTimeout() method in AllocationConfiguration
|
H A D | FairScheduler.java | 477 long minShareTimeout = sched.getMinSharePreemptionTimeout(); in resToPreempt()
|
/dports/devel/hadoop/hadoop-1.2.1/src/contrib/fairscheduler/src/test/org/apache/hadoop/mapred/ |
H A D | TestFairScheduler.java | 707 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 D | FairScheduler.java | 634 long minShareTimeout = poolMgr.getMinSharePreemptionTimeout(pool.getName()); in getAllowedLocalityLevel() 987 long minShareTimeout = poolMgr.getMinSharePreemptionTimeout(pool); in tasksToPreempt()
|
H A D | PoolManager.java | 529 public long getMinSharePreemptionTimeout(String pool) { in getMinSharePreemptionTimeout() method in PoolManager
|