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 e9f4af67450..c4f030b62b6 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);