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/ManagedParentQueue.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/ManagedParentQueue.java index 2494000..6788bb4 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/ManagedParentQueue.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/ManagedParentQueue.java @@ -62,12 +62,10 @@ public ManagedParentQueue(final CapacitySchedulerContext cs, leafQueueTemplate = initializeLeafQueueConfigs().build(); - StringBuffer queueInfo = new StringBuffer(); - queueInfo.append("Created Managed Parent Queue: ").append(queueName).append( - "]\nwith capacity: [").append(super.getCapacity()).append( - "]\nwith max capacity: [").append(super.getMaximumCapacity()).append( - "]."); - LOG.info(queueInfo.toString()); + LOG.info( + "Created Managed Parent Queue: [{}] with capacity: [{}]" + + " with max capacity: [{}]", + queueName, super.getCapacity(), super.getMaximumCapacity()); initializeQueueManagementPolicy(); } @@ -117,12 +115,10 @@ public void reinitialize(CSQueue newlyParsedQueue, Resource clusterResource) validateAndApplyQueueManagementChanges(queueManagementChanges); - StringBuffer queueInfo = new StringBuffer(); - queueInfo.append("Reinitialized Managed Parent Queue: ").append(queueName) - .append("]\nwith capacity: [").append(super.getCapacity()).append( - "]\nwith max capacity: [").append(super.getMaximumCapacity()).append( - "]."); - LOG.info(queueInfo.toString()); + LOG.info( + "Reinitialized Managed Parent Queue: [{}] with capacity [{}]" + + " with max capacity [{}]", + queueName, super.getCapacity(), super.getMaximumCapacity()); } catch (YarnException ye) { LOG.error("Exception while computing policy changes for leaf queue : " + getQueueName(), ye);