YARN-7699. queueUsagePercentage is coming as INF for getApp REST api call. Contributed by Sunil G.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/c2d6fa36 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/c2d6fa36 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/c2d6fa36 Branch: refs/heads/YARN-6592 Commit: c2d6fa36560d122ff24dd7db84f68f4ba3fb8123 Parents: bf5c948 Author: Rohith Sharma K S <rohithsharm...@apache.org> Authored: Mon Jan 8 10:39:31 2018 +0530 Committer: Rohith Sharma K S <rohithsharm...@apache.org> Committed: Mon Jan 8 10:39:31 2018 +0530 ---------------------------------------------------------------------- .../scheduler/common/fica/FiCaSchedulerApp.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/c2d6fa36/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 ---------------------------------------------------------------------- diff --git a/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 b/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 index 776a7e9..d82a258 100644 --- a/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 +++ b/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 @@ -1011,11 +1011,14 @@ public class FiCaSchedulerApp extends SchedulerApplicationAttempt { getAppAMNodePartitionName(), cluster); ResourceCalculator calc = rmContext.getScheduler().getResourceCalculator(); + float queueUsagePerc = 0.0f; if (!calc.isInvalidDivisor(totalPartitionRes)) { Resource effCap = ((AbstractCSQueue) getQueue()) .getEffectiveCapacity(getAppAMNodePartitionName()); - float queueUsagePerc = calc.divide(totalPartitionRes, - report.getUsedResources(), effCap) * 100; + if (!effCap.equals(Resources.none())) { + queueUsagePerc = calc.divide(totalPartitionRes, + report.getUsedResources(), effCap) * 100; + } report.setQueueUsagePercentage(queueUsagePerc); } return report; --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
