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/capacity/CapacityScheduler.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java index 70cce7598a6..8a55e8afc5e 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java @@ -3074,13 +3074,11 @@ public class CapacityScheduler extends long commitSuccess = System.nanoTime() - commitStart; CapacitySchedulerMetrics.getMetrics() .addCommitSuccess(commitSuccess); - LOG.info("Allocation proposal accepted"); isSuccess = true; } else{ long commitFailed = System.nanoTime() - commitStart; CapacitySchedulerMetrics.getMetrics() .addCommitFailure(commitFailed); - LOG.info("Failed to accept allocation proposal"); } if (LOG.isDebugEnabled()) { 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 19b92ab0583..f3d3800be55 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 @@ -358,6 +358,7 @@ public class FiCaSchedulerApp extends SchedulerApplicationAttempt { // adding NP check as this proposal could not be allocated from reserved // container in async-scheduling mode if (allocation.getAllocateFromReservedContainer() == null) { + LOG.debug("Trying to allocate from reserved container in async scheduling mode"); return false; } RMContainer fromReservedContainer = @@ -576,6 +577,8 @@ public class FiCaSchedulerApp extends SchedulerApplicationAttempt { if (updatePending && getOutstandingAsksCount(schedulerContainer.getSchedulerRequestKey()) <= 0) { + LOG.debug("Rejecting appliance of allocation due to existing pending allocation " + + "request for " + schedulerContainer); return false; } @@ -674,10 +677,12 @@ public class FiCaSchedulerApp extends SchedulerApplicationAttempt { schedulerContainer.getRmContainer().getContainer(), reReservation); - LOG.info("Reserved container=" + rmContainer.getContainerId() - + ", on node=" + schedulerContainer.getSchedulerNode() - + " with resource=" + rmContainer - .getAllocatedOrReservedResource()); + if (LOG.isDebugEnabled()) { + LOG.debug("Reserved container=" + rmContainer.getContainerId() + + ", on node=" + schedulerContainer.getSchedulerNode() + + " with resource=" + rmContainer + .getAllocatedOrReservedResource()); + } } } } finally {