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

(cherry picked from commit 27c3b86252)
This commit is contained in:
Naganarasimha 2016-08-26 08:47:21 +05:30
parent 13cbf1677e
commit ee3358402a
4 changed files with 6 additions and 6 deletions

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 class FairSchedulerConfiguration extends Configuration {
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);
} }

View File

@ -84,7 +84,7 @@ public class FairSchedulerTestBase {
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;
} }

View File

@ -1455,7 +1455,7 @@ public class TestFairScheduler extends FairSchedulerTestBase {
// 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();

View File

@ -135,7 +135,7 @@ public class TestFairSchedulerPreemption extends FairSchedulerTestBase {
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);