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/allocator/AbstractContainerAllocator.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/allocator/AbstractContainerAllocator.java index a411f170b5..7baafb025b 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/allocator/AbstractContainerAllocator.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/allocator/AbstractContainerAllocator.java @@ -126,7 +126,8 @@ protected CSAssignment getCSAssignmentFromAllocateResult( LOG.info("assignedContainer" + " application attempt=" + application .getApplicationAttemptId() + " container=" + updatedContainer .getContainerId() + " queue=" + this + " clusterResource=" - + clusterResource + " type=" + assignment.getType()); + + clusterResource + " type=" + assignment.getType() + + " partition=" + updatedContainer.getNodeLabelExpression()); assignment.getAssignmentInformation().addAllocationDetails( updatedContainer, application.getCSLeafQueue().getQueuePath());