diff --git 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 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 d60e8f1e14..b3d33b4848 100644 --- 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 +++ 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 @@ private Resource assignContainer(Resource clusterResource, FiCaSchedulerNode nod // 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 + + " partition=" + label); createdContainer.setValue(allocatedContainer); return container.getResource();