big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

YARN-5564. Fix typo in RM_SCHEDULER_RESERVATION_THRESHOLD_INCREMENT_MULTIPLE. Contributed by Ray Chiang

Browse Source
This commit is contained in:
Naganarasimha 2016-08-26 08:47:21 +05:30
parent f4a21d3aba
commit 27c3b86252
4 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FairSchedulerConfiguration.java
View File

@ -52,7 +52,7 @@ public class FairSchedulerConfiguration extends Configuration {
* multiple of increment allocation. Only container sizes above this are * multiple of increment allocation. Only container sizes above this are
* allowed to reserve a node */ * allowed to reserve a node */
public static final String public static final String
RM_SCHEDULER_RESERVATION_THRESHOLD_INCERMENT_MULTIPLE = RM_SCHEDULER_RESERVATION_THRESHOLD_INCREMENT_MULTIPLE =
YarnConfiguration.YARN_PREFIX + YarnConfiguration.YARN_PREFIX +
"scheduler.reservation-threshold.increment-multiple"; "scheduler.reservation-threshold.increment-multiple";
public static final float public static final float
@ -190,7 +190,7 @@ public Resource getIncrementAllocation() {
public float getReservationThresholdIncrementMultiple() { public float getReservationThresholdIncrementMultiple() {
return getFloat( return getFloat(
RM_SCHEDULER_RESERVATION_THRESHOLD_INCERMENT_MULTIPLE, RM_SCHEDULER_RESERVATION_THRESHOLD_INCREMENT_MULTIPLE,
DEFAULT_RM_SCHEDULER_RESERVATION_THRESHOLD_INCREMENT_MULTIPLE); DEFAULT_RM_SCHEDULER_RESERVATION_THRESHOLD_INCREMENT_MULTIPLE);
} }

4
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FairSchedulerTestBase.java
View File

@ -84,7 +84,7 @@ public Configuration createConfiguration() {
conf.setFloat( conf.setFloat(
FairSchedulerConfiguration FairSchedulerConfiguration
.RM_SCHEDULER_RESERVATION_THRESHOLD_INCERMENT_MULTIPLE, .RM_SCHEDULER_RESERVATION_THRESHOLD_INCREMENT_MULTIPLE,
TEST_RESERVATION_THRESHOLD); TEST_RESERVATION_THRESHOLD);
return conf; return conf;
} }
@ -280,4 +280,4 @@ protected void checkAppConsumption(FSAppAttempt app, Resource resource)
Assert.assertEquals(resource.getVirtualCores(), Assert.assertEquals(resource.getVirtualCores(),
app.getCurrentConsumption().getVirtualCores()); app.getCurrentConsumption().getVirtualCores());
} }
} }

2
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/TestFairScheduler.java
View File

@ -1455,7 +1455,7 @@ public void testReservationThresholdGatesReservations() throws Exception {
// Set threshold to 2 * 1024 ==> 2048 MB & 2 * 1 ==> 2 vcores (test will // Set threshold to 2 * 1024 ==> 2048 MB & 2 * 1 ==> 2 vcores (test will
// use vcores) // use vcores)
conf.setFloat(FairSchedulerConfiguration. conf.setFloat(FairSchedulerConfiguration.
RM_SCHEDULER_RESERVATION_THRESHOLD_INCERMENT_MULTIPLE, RM_SCHEDULER_RESERVATION_THRESHOLD_INCREMENT_MULTIPLE,
2f); 2f);
scheduler.init(conf); scheduler.init(conf);
scheduler.start(); scheduler.start();

2
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/TestFairSchedulerPreemption.java
View File

@ -135,7 +135,7 @@ private void startResourceManagerWithRealFairScheduler() {
conf.setFloat(FairSchedulerConfiguration.PREEMPTION_THRESHOLD, 0f); conf.setFloat(FairSchedulerConfiguration.PREEMPTION_THRESHOLD, 0f);
conf.setFloat( conf.setFloat(
FairSchedulerConfiguration FairSchedulerConfiguration
.RM_SCHEDULER_RESERVATION_THRESHOLD_INCERMENT_MULTIPLE, .RM_SCHEDULER_RESERVATION_THRESHOLD_INCREMENT_MULTIPLE,
TEST_RESERVATION_THRESHOLD); TEST_RESERVATION_THRESHOLD);
resourceManager = new MockRM(conf); resourceManager = new MockRM(conf);