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..37d1defddd6 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; } @@ -211,6 +212,10 @@ public Resource assignContainer(FSSchedulerNode node) { // that queue both need the scheduler lock. TreeSet sortedChildQueues = new TreeSet<>(policy.getComparator()); readLock.lock(); + if (LOG.isDebugEnabled()) { + LOG.debug("Node " + node.getNodeName() + " offered to parent queue: " + + getName() + " visiting " + childQueues.size() + " children"); + } try { sortedChildQueues.addAll(childQueues); for (FSQueue child : sortedChildQueues) {