Repository: hadoop Updated Branches: refs/heads/branch-2.7 cecedcf55 -> e9575d7da
YARN-6493. Print requested node partition in assignContainer logs. (Jonathan Hung via wangda) Change-Id: I6b045ebf0be09bcc73d4bf009ca60a59f9626916 Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/e9575d7d Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/e9575d7d Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/e9575d7d Branch: refs/heads/branch-2.7 Commit: e9575d7dae67840d67e952e05f9e1bb6219e9d95 Parents: cecedcf Author: Wangda Tan <[email protected]> Authored: Mon May 22 15:00:31 2017 -0700 Committer: Wangda Tan <[email protected]> Committed: Mon May 22 15:04:09 2017 -0700 ---------------------------------------------------------------------- .../server/resourcemanager/scheduler/capacity/LeafQueue.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/e9575d7d/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.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/capacity/LeafQueue.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.java index d60e8f1..99d0368 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/LeafQueue.java @@ -1551,12 +1551,17 @@ public class LeafQueue extends AbstractCSQueue { // Inform the node node.allocateContainer(allocatedContainer); + String label = RMNodeLabelsManager.NO_LABEL; + if (node.getLabels() != null && !node.getLabels().isEmpty()) { + label = node.getLabels().iterator().next(); + } LOG.info("assignedContainer" + " application attempt=" + application.getApplicationAttemptId() + " container=" + container + " queue=" + this + " clusterResource=" + clusterResource + - " type=" + type); + " type=" + type + + " requestedPartition=" + label); createdContainer.setValue(allocatedContainer); return container.getResource(); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
