From b3c75c1f1d347d1a9e5bd54decf27babb6a309f6 Mon Sep 17 00:00:00 2001 From: Haibo Chen Date: Wed, 5 Dec 2018 15:02:57 -0800 Subject: [PATCH] YARN-8985. Improve debug log in FSParentQueue when assigning container. (Contributed by Wilfred Spiegelenburg) --- .../resourcemanager/scheduler/fair/FSParentQueue.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) 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/FSParentQueue.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/FSParentQueue.java index 9a52d37efe..56a490b831 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/FSParentQueue.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/FSParentQueue.java @@ -196,7 +196,8 @@ public Resource assignContainer(FSSchedulerNode node) { // If this queue is over its limit, reject if (!assignContainerPreCheck(node)) { if (LOG.isDebugEnabled()) { - LOG.debug("Assign container precheck on node " + node + " failed"); + LOG.debug("Assign container precheck for queue " + getName() + + " on node " + node.getNodeName() + " failed"); } return assigned; } @@ -212,6 +213,10 @@ public Resource assignContainer(FSSchedulerNode node) { TreeSet sortedChildQueues = new TreeSet<>(policy.getComparator()); readLock.lock(); try { + if (LOG.isDebugEnabled()) { + LOG.debug("Node " + node.getNodeName() + " offered to parent queue: " + + getName() + " visiting " + childQueues.size() + " children"); + } sortedChildQueues.addAll(childQueues); for (FSQueue child : sortedChildQueues) { assigned = child.assignContainer(node);