From 128d773a2315fa6baaa3a52b13c53c77e741b69c Mon Sep 17 00:00:00 2001 From: Sunil G Date: Fri, 12 Jan 2018 15:41:19 +0530 Subject: [PATCH] YARN-7727. Incorrect log levels in few logs with QueuePriorityContainerCandidateSelector. Contributed by Prabhu Joseph. --- .../QueuePriorityContainerCandidateSelector.java | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/monitor/capacity/QueuePriorityContainerCandidateSelector.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/monitor/capacity/QueuePriorityContainerCandidateSelector.java index 7b7404caf3..d75f329c17 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/monitor/capacity/QueuePriorityContainerCandidateSelector.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/monitor/capacity/QueuePriorityContainerCandidateSelector.java @@ -118,8 +118,9 @@ private List getPathToRoot(TempQueuePerPartition tq) { } private void intializePriorityDigraph() { - LOG.info("Initializing priority preemption directed graph:"); - + if (LOG.isDebugEnabled()) { + LOG.debug("Initializing priority preemption directed graph:"); + } // Make sure we iterate all leaf queue combinations for (String q1 : preemptionContext.getLeafQueueNames()) { for (String q2 : preemptionContext.getLeafQueueNames()) { @@ -148,12 +149,12 @@ private void intializePriorityDigraph() { if (p1 < p2) { priorityDigraph.put(q2, q1, true); if (LOG.isDebugEnabled()) { - LOG.info("- Added priority ordering edge: " + q2 + " >> " + q1); + LOG.debug("- Added priority ordering edge: " + q2 + " >> " + q1); } } else if (p2 < p1) { priorityDigraph.put(q1, q2, true); if (LOG.isDebugEnabled()) { - LOG.info("- Added priority ordering edge: " + q1 + " >> " + q2); + LOG.debug("- Added priority ordering edge: " + q1 + " >> " + q2); } } } @@ -506,4 +507,4 @@ public Map> selectCandidates( return selectedCandidates; } -} \ No newline at end of file +}