From 524374098a325a74a73a0c03f2386fa26fc89e15 Mon Sep 17 00:00:00 2001 From: fuchaohong Date: Tue, 17 Jun 2025 17:02:17 +0800 Subject: [PATCH] =?UTF-8?q?YARN-11827.=20Fix=20the=20bug=20of=20=E2=80=9CR?= =?UTF-8?q?'moving=20extra=20containersr'when=20autoCorrectContainerAlloca?= =?UTF-8?q?tion=20is=20enabled.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../resourcemanager/scheduler/AbstractYarnScheduler.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/AbstractYarnScheduler.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/AbstractYarnScheduler.java index 3343c5f93118d..512aab7167a08 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/AbstractYarnScheduler.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/AbstractYarnScheduler.java @@ -692,8 +692,8 @@ protected void autoCorrectContainerAllocation(List resourceRequ request.getCapability()); int numContainerAllocated = allocatedContainerMap.getOrDefault(containerObjectType, Collections.emptyList()).size(); - if (numContainerAllocated > 0) { - int numContainerAsk = request.getNumContainers(); + int numContainerAsk = request.getNumContainers(); + if (numContainerAllocated > 0 && numContainerAsk > 0) { int updatedContainerRequest = numContainerAsk - numContainerAllocated; if (updatedContainerRequest < 0) { // add an entry to extra allocated map