From 8e0f83e49a8987cf45a72c8a9bb8587b86e4c0ed Mon Sep 17 00:00:00 2001 From: Wangda Tan Date: Mon, 22 May 2017 14:28:55 -0700 Subject: [PATCH] YARN-6493. Print requested node partition in assignContainer logs. (Jonathan Hung via wangda) Change-Id: Ib20326daac10acad363befb0ae0998441fa5b32d --- .../capacity/allocator/AbstractContainerAllocator.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) 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/allocator/AbstractContainerAllocator.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/allocator/AbstractContainerAllocator.java index a411f170b5..5809d86e6d 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/allocator/AbstractContainerAllocator.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/allocator/AbstractContainerAllocator.java @@ -126,7 +126,9 @@ protected CSAssignment getCSAssignmentFromAllocateResult( LOG.info("assignedContainer" + " application attempt=" + application .getApplicationAttemptId() + " container=" + updatedContainer .getContainerId() + " queue=" + this + " clusterResource=" - + clusterResource + " type=" + assignment.getType()); + + clusterResource + " type=" + assignment.getType() + + " requestedPartition=" + + updatedContainer.getNodeLabelExpression()); assignment.getAssignmentInformation().addAllocationDetails( updatedContainer, application.getCSLeafQueue().getQueuePath()); @@ -183,4 +185,4 @@ protected CSAssignment getCSAssignmentFromAllocateResult( public abstract CSAssignment assignContainers(Resource clusterResource, PlacementSet ps, SchedulingMode schedulingMode, ResourceLimits resourceLimits, RMContainer reservedContainer); -} \ No newline at end of file +}