diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/monitor/ContainersMonitorImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/monitor/ContainersMonitorImpl.java index 76bbda1..1b02d8d 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/monitor/ContainersMonitorImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/monitor/ContainersMonitorImpl.java @@ -346,6 +346,7 @@ public MonitoringThread() { super("Container Monitor"); } + @SuppressWarnings("unchecked") @Override public void run() { @@ -389,8 +390,6 @@ public void run() { // Now do the monitoring for the trackingContainers // Check memory usage and kill any overflowing containers - long vmemStillInUsage = 0; - long pmemStillInUsage = 0; for (Iterator> it = trackingContainers.entrySet().iterator(); it.hasNext();) { @@ -520,12 +519,6 @@ public void run() { containerExitStatus, msg)); it.remove(); LOG.info("Removed ProcessTree with root " + pId); - } else { - // Accounting the total memory in usage for all containers that - // are still - // alive and within limits. - vmemStillInUsage += currentVmemUsage; - pmemStillInUsage += currentPmemUsage; } } catch (Exception e) { // Log the exception and proceed to the next container.