diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/scheduler/OpportunisticContainerAllocator.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/scheduler/OpportunisticContainerAllocator.java index 1f53648d55d..096cc8e6566 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/scheduler/OpportunisticContainerAllocator.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/scheduler/OpportunisticContainerAllocator.java @@ -410,7 +410,7 @@ private void allocateContainersInternal(long rmIdentifier, // Ignore black list if (blacklist.contains(rNodeHost)) { LOG.info("Nodes for scheduling has a blacklisted node" + - " [" + rNodeHost + "].."); + " [" + rNodeHost + "]."); continue; } String location = ResourceRequest.ANY; diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/scheduler/OpportunisticContainerContext.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/scheduler/OpportunisticContainerContext.java index 246d450668d..72cf23e6e68 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/scheduler/OpportunisticContainerContext.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/scheduler/OpportunisticContainerContext.java @@ -149,11 +149,10 @@ public void addToOutstandingReqs(List resourceAsks) { } if (ResourceRequest.isAnyLocation(request.getResourceName())) { LOG.info("# of outstandingOpReqs in ANY (at " - + "priority = " + schedulerKey.getPriority() - + ", allocationReqId = " + schedulerKey.getAllocationRequestId() - + ", with capability = " + request.getCapability() + " ) : " - + ", with location = " + request.getResourceName() + " ) : " - + ", numContainers = " + eReq.getRequest().getNumContainers()); + + "priority=" + schedulerKey.getPriority() + + ", allocationReqId=" + schedulerKey.getAllocationRequestId() + + ", with capability=" + request.getCapability() + ")" + + ", numContainers=" + request.getNumContainers()); } } } diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/AMSProcessingChain.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/AMSProcessingChain.java index 7ae23e7bb63..db35b453f1c 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/AMSProcessingChain.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/AMSProcessingChain.java @@ -72,8 +72,8 @@ public void init(ApplicationMasterServiceContext amsContext, */ public synchronized void addProcessor( ApplicationMasterServiceProcessor processor) { - LOG.info("Adding [" + processor.getClass().getName() + "] tp top of" + - " AMS Processing chain. "); + LOG.info("Adding [" + processor.getClass().getName() + "] " + + "to the top of AMS Processing chain."); processor.init(this.rmContext, this.head); this.head = processor; }