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 (date 1555361229000) +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/SchedulerApplicationAttempt.java (date 1555568862000) @@ -626,6 +626,15 @@ readLock.unlock(); } } + + public int getTotalNumReservedContainers() { + readLock.lock(); + try { + return reservedContainers.values().stream().mapToInt(Map::size).sum(); + } finally { + readLock.unlock(); + } + } @SuppressWarnings("unchecked") public void containerLaunchedOnNode(ContainerId containerId, @@ -1133,7 +1142,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,