diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FairScheduler.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FairScheduler.java index 7a4e79c..a3000f5 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FairScheduler.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FairScheduler.java @@ -275,6 +275,13 @@ protected synchronized void update() { // Recursively compute fair shares for all queues // and update metrics rootQueue.recomputeShares(); + + if (LOG.isDebugEnabled()) { + LOG.debug("Cluster Capacity: " + clusterResource + + " Allocations: " + rootMetrics.getAllocatedResources() + + " Availability: " + Resource.newInstance( + rootMetrics.getAvailableMB(), rootMetrics.getAvailableVirtualCores())); + } } /** @@ -879,14 +886,14 @@ public Allocation allocate(ApplicationAttemptId appAttemptId, // Update application requests application.updateResourceRequests(ask); - LOG.debug("allocate: post-update"); application.showRequests(); } if (LOG.isDebugEnabled()) { - LOG.debug("allocate:" + + LOG.debug("allocate: post-update" + " applicationAttemptId=" + appAttemptId + - " #ask=" + ask.size()); + " #ask=" + ask.size() + + " reservation= " + application.getCurrentReservation()); LOG.debug("Preempting " + application.getPreemptionContainers().size() + " container(s)");