big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

YARN-8165. Incorrect queue name logging in AbstractContainerAllocator. Contributed by Weiwei Yan.

Browse Source
This commit is contained in:
Inigo Goiri 2018-04-16 16:52:17 -07:00
parent 60e5c1b516
commit dd5e18c4ae
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
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
View File

@ -96,7 +96,8 @@ protected CSAssignment getCSAssignmentFromAllocateResult(
// This is a reserved container // This is a reserved container
LOG.info("Reserved container " + " application=" LOG.info("Reserved container " + " application="
+ application.getApplicationId() + " resource=" + allocatedResource + application.getApplicationId() + " resource=" + allocatedResource
+ " queue=" + this.toString() + " cluster=" + clusterResource); + " queue=" + appInfo.getQueueName()
+ " cluster=" + clusterResource);
assignment.getAssignmentInformation().addReservationDetails( assignment.getAssignmentInformation().addReservationDetails(
updatedContainer, application.getCSLeafQueue().getQueuePath()); updatedContainer, application.getCSLeafQueue().getQueuePath());
assignment.getAssignmentInformation().incrReservations(); assignment.getAssignmentInformation().incrReservations();
@ -124,9 +125,9 @@ protected CSAssignment getCSAssignmentFromAllocateResult(
// Inform the ordering policy // Inform the ordering policy
LOG.info("assignedContainer" + " application attempt=" + application LOG.info("assignedContainer" + " application attempt=" + application
.getApplicationAttemptId() + " container=" + updatedContainer .getApplicationAttemptId() + " container=" + updatedContainer
.getContainerId() + " queue=" + this + " clusterResource=" .getContainerId() + " queue=" + appInfo.getQueueName()
+ clusterResource + " type=" + assignment.getType() + " clusterResource=" + clusterResource
+ " requestedPartition=" + " type=" + assignment.getType() + " requestedPartition="
+ updatedContainer.getNodeLabelExpression()); + updatedContainer.getNodeLabelExpression());
assignment.getAssignmentInformation().addAllocationDetails( assignment.getAssignmentInformation().addAllocationDetails(