|
@@ -800,10 +800,11 @@ public class CapacitySchedulerConfiguration extends ReservationSchedulerConfigur
|
|
|
// root.From AbstractCSQueue, absolute resource, and weight will be parsed
|
|
|
// and updated separately. Once nodes are added/removed in cluster,
|
|
|
// capacity is 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
|
|
|
|| capacity > MAXIMUM_CAPACITY_VALUE) {
|
|
|
throw new IllegalArgumentException(
|