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/fair/FairScheduler.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FairScheduler.java index 2801bee..917fc8a 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FairScheduler.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FairScheduler.java @@ -889,7 +889,7 @@ private synchronized void addNode(List containerReports, } else { nodesPerRack.put(rackName, 1); } - Resources.addTo(clusterResource, node.getTotalCapability()); + Resources.addTo(clusterResource, schedulerNode.getTotalResource()); updateMaximumAllocation(schedulerNode, true); triggerUpdate(); @@ -909,7 +909,7 @@ private synchronized void removeNode(RMNode rmNode) { if (node == null) { return; } - Resources.subtractFrom(clusterResource, rmNode.getTotalCapability()); + Resources.subtractFrom(clusterResource, node.getTotalResource()); updateRootQueueMetrics(); triggerUpdate();