Skip to content

Commit 5c25f3b

Browse files
committed
YARN-11082 AbstractCSQueue#canAssignToThisQueue use node partition resource as denominator
1 parent 12fa38d commit 5c25f3b

File tree

1 file changed

+5
-2
lines changed
  • hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity

1 file changed

+5
-2
lines changed

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/AbstractCSQueue.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -845,8 +845,11 @@ boolean canAssignToThisQueue(Resource clusterResource,
845845
currentResourceLimits.setHeadroom(
846846
Resources.subtract(currentLimitResource, usedExceptKillable));
847847

848-
if (Resources.greaterThanOrEqual(resourceCalculator, clusterResource,
849-
usedExceptKillable, currentLimitResource)) {
848+
if (Resources.greaterThanOrEqual(
849+
resourceCalculator,
850+
labelManager.getResourceByLabel(nodePartition, clusterResource),
851+
usedExceptKillable,
852+
currentLimitResource)) {
850853

851854
// if reservation continue looking enabled, check to see if could we
852855
// potentially use this node instead of a reserved node if the application

0 commit comments

Comments
 (0)