Skip to content

Commit 5243740

Browse files
author
fuchaohong
committed
YARN-11827. Fix the bug of “R'moving extra containersr'when autoCorrectContainerAllocation is enabled.
1 parent 43b5183 commit 5243740

File tree

1 file changed

+2
-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

1 file changed

+2
-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/AbstractYarnScheduler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -692,8 +692,8 @@ protected void autoCorrectContainerAllocation(List<ResourceRequest> resourceRequ
692692
request.getCapability());
693693
int numContainerAllocated = allocatedContainerMap.getOrDefault(containerObjectType,
694694
Collections.emptyList()).size();
695-
if (numContainerAllocated > 0) {
696-
int numContainerAsk = request.getNumContainers();
695+
int numContainerAsk = request.getNumContainers();
696+
if (numContainerAllocated > 0 && numContainerAsk > 0) {
697697
int updatedContainerRequest = numContainerAsk - numContainerAllocated;
698698
if (updatedContainerRequest < 0) {
699699
// add an entry to extra allocated map

0 commit comments

Comments
 (0)