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

YARN-8985. Improve debug log in FSParentQueue when assigning container. (Contributed by Wilfred Spiegelenburg)

Browse Source
This commit is contained in:
Haibo Chen 2018-12-05 15:02:57 -08:00
parent 2bba329c14
commit b3c75c1f1d
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -196,7 +196,8 @@ public Resource assignContainer(FSSchedulerNode node) {
// If this queue is over its limit, reject // If this queue is over its limit, reject
if (!assignContainerPreCheck(node)) { if (!assignContainerPreCheck(node)) {
if (LOG.isDebugEnabled()) { 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; return assigned;
} }
@ -212,6 +213,10 @@ public Resource assignContainer(FSSchedulerNode node) {
TreeSet<FSQueue> sortedChildQueues = new TreeSet<>(policy.getComparator()); TreeSet<FSQueue> sortedChildQueues = new TreeSet<>(policy.getComparator());
readLock.lock(); readLock.lock();
try { try {
if (LOG.isDebugEnabled()) {
LOG.debug("Node " + node.getNodeName() + " offered to parent queue: " +
getName() + " visiting " + childQueues.size() + " children");
}
sortedChildQueues.addAll(childQueues); sortedChildQueues.addAll(childQueues);
for (FSQueue child : sortedChildQueues) { for (FSQueue child : sortedChildQueues) {
assigned = child.assignContainer(node); assigned = child.assignContainer(node);