Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

YARN-6969. Clean up unused code in class FairSchedulerQueueInfo. (Larry Lo via Yufei Gu)

This commit is contained in:
Yufei Gu 2017-08-18 14:38:44 -07:00
parent 2d105a2068
commit 8991f0baec
1 changed files with 0 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
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
View File

@ -48,8 +48,6 @@ public class FairSchedulerQueueInfo {
@XmlTransient @XmlTransient
private float fractionMemFairShare; private float fractionMemFairShare;
@XmlTransient @XmlTransient
private float fractionMemMinShare;
@XmlTransient
private float fractionMemMaxShare; private float fractionMemMaxShare;
private ResourceInfo minResources; private ResourceInfo minResources;
@ -63,7 +61,6 @@ public class FairSchedulerQueueInfo {
private ResourceInfo clusterResources; private ResourceInfo clusterResources;
private ResourceInfo reservedResources; private ResourceInfo reservedResources;
private long pendingContainers;
private long allocatedContainers; private long allocatedContainers;
private long reservedContainers; private long reservedContainers;
@ -108,12 +105,10 @@ public FairSchedulerQueueInfo(FSQueue queue, FairScheduler scheduler) {
(float)steadyFairResources.getMemorySize() / clusterResources.getMemorySize(); (float)steadyFairResources.getMemorySize() / clusterResources.getMemorySize();
fractionMemFairShare = (float) fairResources.getMemorySize() fractionMemFairShare = (float) fairResources.getMemorySize()
/ clusterResources.getMemorySize(); / clusterResources.getMemorySize();
fractionMemMinShare = (float)minResources.getMemorySize() / clusterResources.getMemorySize();
fractionMemMaxShare = (float)maxResources.getMemorySize() / clusterResources.getMemorySize(); fractionMemMaxShare = (float)maxResources.getMemorySize() / clusterResources.getMemorySize();
maxApps = queue.getMaxRunningApps(); maxApps = queue.getMaxRunningApps();
pendingContainers = queue.getMetrics().getPendingContainers();
allocatedContainers = queue.getMetrics().getAllocatedContainers(); allocatedContainers = queue.getMetrics().getAllocatedContainers();
reservedContainers = queue.getMetrics().getReservedContainers(); reservedContainers = queue.getMetrics().getReservedContainers();
@ -126,10 +121,6 @@ public FairSchedulerQueueInfo(FSQueue queue, FairScheduler scheduler) {
childQueues = getChildQueues(queue, scheduler); childQueues = getChildQueues(queue, scheduler);
} }
public long getPendingContainers() {
return pendingContainers;
}
public long getAllocatedContainers() { public long getAllocatedContainers() {
return allocatedContainers; return allocatedContainers;
} }
@ -233,14 +224,6 @@ public ResourceInfo getDemandResources() {
return demandResources; 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 * Returns the memory used by this queue as a fraction of the entire
* cluster capacity. * cluster capacity.