Index: hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/SchedulerApplicationAttempt.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/SchedulerApplicationAttempt.java (revision 5583e1b6fcfd5651857ada7ed851f09fc19969bc) +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/SchedulerApplicationAttempt.java (revision c458936483cd9ce28586d0400935daa3b8dc8cb0) @@ -626,6 +626,20 @@ readLock.unlock(); } } + + public int getTotalNumReservedContainers() { + readLock.lock(); + try { + int num = 0; + for (Entry> e : + this.reservedContainers.entrySet()) { + num += e.getValue().size(); + } + return num; + } finally { + readLock.unlock(); + } + } @SuppressWarnings("unchecked") public void containerLaunchedOnNode(ContainerId containerId, @@ -1133,7 +1147,7 @@ calc.divide(cluster, usedResourceClone, cluster) * 100; } return ApplicationResourceUsageReport - .newInstance(liveContainers.size(), reservedContainers.size(), + .newInstance(liveContainers.size(), getTotalNumReservedContainers(), usedResourceClone, reservedResourceClone, Resources.add(usedResourceClone, reservedResourceClone), runningResourceUsage.getResourceUsageSecondsMap(), queueUsagePerc,