From 4bd417a05609bd2c654a210d4d51d1e41489ba3c Mon Sep 17 00:00:00 2001 From: Yufei Gu Date: Fri, 18 Aug 2017 14:38:44 -0700 Subject: [PATCH] YARN-6969. Clean up unused code in class FairSchedulerQueueInfo. (Larry Lo via Yufei Gu) (cherry picked from commit 8991f0baec62625c45144e2544066195800ab95b) --- .../webapp/dao/FairSchedulerQueueInfo.java | 17 ----------------- 1 file changed, 17 deletions(-) diff --git a/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 b/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 cd5efc711fc..b5ba002280e 100644 --- a/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 +++ b/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 @@ -48,8 +48,6 @@ public class FairSchedulerQueueInfo { @XmlTransient private float fractionMemFairShare; @XmlTransient - private float fractionMemMinShare; - @XmlTransient private float fractionMemMaxShare; private ResourceInfo minResources; @@ -63,7 +61,6 @@ public class FairSchedulerQueueInfo { private ResourceInfo clusterResources; private ResourceInfo reservedResources; - private long pendingContainers; private long allocatedContainers; private long reservedContainers; @@ -109,12 +106,10 @@ public class FairSchedulerQueueInfo { (float)steadyFairResources.getMemorySize() / clusterResources.getMemorySize(); fractionMemFairShare = (float) fairResources.getMemorySize() / clusterResources.getMemorySize(); - fractionMemMinShare = (float)minResources.getMemorySize() / clusterResources.getMemorySize(); fractionMemMaxShare = (float)maxResources.getMemorySize() / clusterResources.getMemorySize(); maxApps = queue.getMaxRunningApps(); - pendingContainers = queue.getMetrics().getPendingContainers(); allocatedContainers = queue.getMetrics().getAllocatedContainers(); reservedContainers = queue.getMetrics().getReservedContainers(); @@ -127,10 +122,6 @@ public class FairSchedulerQueueInfo { childQueues = getChildQueues(queue, scheduler); } - public long getPendingContainers() { - return pendingContainers; - } - public long getAllocatedContainers() { return allocatedContainers; } @@ -234,14 +225,6 @@ public class FairSchedulerQueueInfo { return demandResources; } - /** - * Returns the queue's min share in as a fraction of the entire - * cluster capacity. - */ - public float getMinShareMemoryFraction() { - return fractionMemMinShare; - } - /** * Returns the memory used by this queue as a fraction of the entire * cluster capacity.