|
@@ -158,13 +158,13 @@ public class FSParentQueue extends FSQueue {
|
|
for (FSQueue childQueue : childQueues) {
|
|
for (FSQueue childQueue : childQueues) {
|
|
childQueue.updateDemand();
|
|
childQueue.updateDemand();
|
|
Resource toAdd = childQueue.getDemand();
|
|
Resource toAdd = childQueue.getDemand();
|
|
|
|
+ demand = Resources.add(demand, toAdd);
|
|
|
|
+ demand = Resources.componentwiseMin(demand, maxShare);
|
|
if (LOG.isDebugEnabled()) {
|
|
if (LOG.isDebugEnabled()) {
|
|
LOG.debug("Counting resource from " + childQueue.getName() + " " +
|
|
LOG.debug("Counting resource from " + childQueue.getName() + " " +
|
|
- toAdd + "; Total resource consumption for " + getName() +
|
|
|
|
|
|
+ toAdd + "; Total resource demand for " + getName() +
|
|
" now " + demand);
|
|
" now " + demand);
|
|
}
|
|
}
|
|
- demand = Resources.add(demand, toAdd);
|
|
|
|
- demand = Resources.componentwiseMin(demand, maxShare);
|
|
|
|
if (Resources.equals(demand, maxShare)) {
|
|
if (Resources.equals(demand, maxShare)) {
|
|
break;
|
|
break;
|
|
}
|
|
}
|