Repository: hadoop Updated Branches: refs/heads/trunk 2bba329c1 -> b3c75c1f1
YARN-8985. Improve debug log in FSParentQueue when assigning container. (Contributed by Wilfred Spiegelenburg) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/b3c75c1f Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/b3c75c1f Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/b3c75c1f Branch: refs/heads/trunk Commit: b3c75c1f1d347d1a9e5bd54decf27babb6a309f6 Parents: 2bba329 Author: Haibo Chen <haiboc...@apache.org> Authored: Wed Dec 5 15:02:57 2018 -0800 Committer: Haibo Chen <haiboc...@apache.org> Committed: Wed Dec 5 15:02:57 2018 -0800 ---------------------------------------------------------------------- .../server/resourcemanager/scheduler/fair/FSParentQueue.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/b3c75c1f/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 ---------------------------------------------------------------------- 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 9a52d37..56a490b 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 class FSParentQueue extends FSQueue { // 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 class FSParentQueue extends FSQueue { TreeSet<FSQueue> 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); --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
