big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

YARN-7727. Incorrect log levels in few logs with QueuePriorityContainerCandidateSelector. Contributed by Prabhu Joseph.

Browse Source
This commit is contained in:
Sunil G 2018-01-12 15:41:19 +05:30
parent addbcd8cd4
commit 128d773a23
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
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
View File

@ -118,8 +118,9 @@ private List<TempQueuePerPartition> 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);
}
}
}