|
@@ -391,7 +391,10 @@ public class CapacityScheduler extends
|
|
|
+ getMaximumResourceCapability() + ">, " + "asynchronousScheduling="
|
|
|
+ scheduleAsynchronously + ", " + "asyncScheduleInterval="
|
|
|
+ asyncScheduleInterval + "ms" + ",multiNodePlacementEnabled="
|
|
|
- + multiNodePlacementEnabled);
|
|
|
+ + multiNodePlacementEnabled + ", " + "assignMultipleEnabled="
|
|
|
+ + assignMultipleEnabled + ", " + "maxAssignPerHeartbeat="
|
|
|
+ + maxAssignPerHeartbeat + ", " + "offswitchPerHeartbeatLimit="
|
|
|
+ + offswitchPerHeartbeatLimit);
|
|
|
} finally {
|
|
|
writeLock.unlock();
|
|
|
}
|
|
@@ -483,8 +486,14 @@ public class CapacityScheduler extends
|
|
|
this.isLazyPreemptionEnabled = this.conf.getLazyPreemptionEnabled();
|
|
|
|
|
|
// Setup how many containers we can allocate for each round
|
|
|
+ assignMultipleEnabled = this.conf.getAssignMultipleEnabled();
|
|
|
+ maxAssignPerHeartbeat = this.conf.getMaxAssignPerHeartbeat();
|
|
|
offswitchPerHeartbeatLimit = this.conf.getOffSwitchPerHeartbeatLimit();
|
|
|
|
|
|
+ LOG.info("assignMultipleEnabled = " + assignMultipleEnabled + "\n" +
|
|
|
+ "maxAssignPerHeartbeat = " + maxAssignPerHeartbeat + "\n" +
|
|
|
+ "offswitchPerHeartbeatLimit = " + offswitchPerHeartbeatLimit);
|
|
|
+
|
|
|
super.reinitialize(newConf, rmContext);
|
|
|
}
|
|
|
maxRunningEnforcer.updateRunnabilityOnReload();
|