diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/dao/FairSchedulerQueueInfo.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/dao/FairSchedulerQueueInfo.java index ee37f18..c68f251 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/dao/FairSchedulerQueueInfo.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/dao/FairSchedulerQueueInfo.java @@ -57,6 +57,7 @@ private ResourceInfo steadyFairResources; private ResourceInfo fairResources; private ResourceInfo clusterResources; + private ResourceInfo demand; private long pendingContainers; private long allocatedContainers; @@ -75,7 +76,7 @@ public FairSchedulerQueueInfo(FSQueue queue, FairScheduler scheduler) { queueName = queue.getName(); schedulingPolicy = queue.getPolicy().getName(); - + clusterResources = new ResourceInfo(scheduler.getClusterResource()); usedResources = new ResourceInfo(queue.getResourceUsage()); @@ -89,6 +90,7 @@ public FairSchedulerQueueInfo(FSQueue queue, FairScheduler scheduler) { maxResources = new ResourceInfo( Resources.componentwiseMin(queue.getMaxShare(), scheduler.getClusterResource())); + demand = new ResourceInfo(queue.getDemand()); fractionMemSteadyFairShare = (float)steadyFairResources.getMemory() / clusterResources.getMemory(); @@ -180,7 +182,11 @@ public ResourceInfo getMinResources() { public ResourceInfo getMaxResources() { return maxResources; } - + + public ResourceInfo getDemand() { + return demand; + } + public int getMaxApplications() { return maxApps; }