From 8943abfb089a49b4f39eba321c3bd4b882e9bcee Mon Sep 17 00:00:00 2001 From: Arun Suresh Date: Thu, 29 Oct 2015 13:42:09 -0700 Subject: [PATCH] YARN-4310. FairScheduler: Log skipping reservation messages at DEBUG level (asuresh) (cherry picked from commit 58d1df585c2b8a4d2f78ae30726f07b4c6a94731) --- hadoop-yarn-project/CHANGES.txt | 2 ++ .../scheduler/fair/FSAppAttempt.java | 16 +++++++++------- 2 files changed, 11 insertions(+), 7 deletions(-) diff --git a/hadoop-yarn-project/CHANGES.txt b/hadoop-yarn-project/CHANGES.txt index 63b27d5472f..efe526ce5ae 100644 --- a/hadoop-yarn-project/CHANGES.txt +++ b/hadoop-yarn-project/CHANGES.txt @@ -497,6 +497,8 @@ Release 2.8.0 - UNRELEASED YARN-3216. Max-AM-Resource-Percentage should respect node labels. (Sunil G via wangda) + YARN-4310. FairScheduler: Log skipping reservation messages at DEBUG level (asuresh) + OPTIMIZATIONS YARN-3339. TestDockerContainerExecutor should pull a single image and not 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/fair/FSAppAttempt.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSAppAttempt.java index 6da4ebf18d1..abbf77a465b 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSAppAttempt.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSAppAttempt.java @@ -488,13 +488,15 @@ private boolean reservationExceedsThreshold(FSSchedulerNode node, if (existingReservations >= numAllowedReservations) { DecimalFormat df = new DecimalFormat(); df.setMaximumFractionDigits(2); - LOG.info("Reservation Exceeds Allowed number of nodes:" + - " app_id=" + getApplicationId() + - " existingReservations=" + existingReservations + - " totalAvailableNodes=" + totalAvailNodes + - " reservableNodesRatio=" + df.format( - scheduler.getReservableNodesRatio()) + - " numAllowedReservations=" + numAllowedReservations); + if (LOG.isDebugEnabled()) { + LOG.debug("Reservation Exceeds Allowed number of nodes:" + + " app_id=" + getApplicationId() + + " existingReservations=" + existingReservations + + " totalAvailableNodes=" + totalAvailNodes + + " reservableNodesRatio=" + df.format( + scheduler.getReservableNodesRatio()) + + " numAllowedReservations=" + numAllowedReservations); + } return true; } }