|
@@ -697,10 +697,11 @@ public class CapacitySchedulerConfiguration extends ReservationSchedulerConfigur
|
|
// root.From AbstractCSQueue, absolute resource will be parsed and
|
|
// root.From AbstractCSQueue, absolute resource will be parsed and
|
|
// updated. Once nodes are added/removed in cluster, capacity in
|
|
// updated. Once nodes are added/removed in cluster, capacity in
|
|
// percentage will also be re-calculated.
|
|
// percentage will also be re-calculated.
|
|
- return defaultValue;
|
|
|
|
|
|
+ return queue.equals("root") ? 100.0f : defaultValue;
|
|
}
|
|
}
|
|
|
|
|
|
- float capacity = getFloat(capacityPropertyName, defaultValue);
|
|
|
|
|
|
+ float capacity = queue.equals("root") ? 100.0f
|
|
|
|
+ : getFloat(capacityPropertyName, defaultValue);
|
|
if (capacity < MINIMUM_CAPACITY_VALUE
|
|
if (capacity < MINIMUM_CAPACITY_VALUE
|
|
|| capacity > MAXIMUM_CAPACITY_VALUE) {
|
|
|| capacity > MAXIMUM_CAPACITY_VALUE) {
|
|
throw new IllegalArgumentException("Illegal capacity of " + capacity
|
|
throw new IllegalArgumentException("Illegal capacity of " + capacity
|