You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by ha...@apache.org on 2018/12/05 23:04:12 UTC
hadoop git commit: YARN-8985. Improve debug log in FSParentQueue when
assigning container. (Contributed by Wilfred Spiegelenburg)
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 <ha...@apache.org>
Authored: Wed Dec 5 15:02:57 2018 -0800
Committer: Haibo Chen <ha...@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-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org