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

YARN-7699. queueUsagePercentage is coming as INF for getApp REST api call. Contributed by Sunil G.

This commit is contained in:
Rohith Sharma K S 2018-01-08 10:39:31 +05:30
parent bf5c948995
commit c2d6fa3656
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/common/fica/FiCaSchedulerApp.java
View File

@ -1011,11 +1011,14 @@ public class FiCaSchedulerApp extends SchedulerApplicationAttempt {
getAppAMNodePartitionName(), cluster); getAppAMNodePartitionName(), cluster);
ResourceCalculator calc = ResourceCalculator calc =
rmContext.getScheduler().getResourceCalculator(); rmContext.getScheduler().getResourceCalculator();
float queueUsagePerc = 0.0f;
if (!calc.isInvalidDivisor(totalPartitionRes)) { if (!calc.isInvalidDivisor(totalPartitionRes)) {
Resource effCap = ((AbstractCSQueue) getQueue()) Resource effCap = ((AbstractCSQueue) getQueue())
.getEffectiveCapacity(getAppAMNodePartitionName()); .getEffectiveCapacity(getAppAMNodePartitionName());
float queueUsagePerc = calc.divide(totalPartitionRes, if (!effCap.equals(Resources.none())) {
report.getUsedResources(), effCap) * 100; queueUsagePerc = calc.divide(totalPartitionRes,
report.getUsedResources(), effCap) * 100;
}
report.setQueueUsagePercentage(queueUsagePerc); report.setQueueUsagePercentage(queueUsagePerc);
} }
return report; return report;