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/AbstractCSQueue.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/AbstractCSQueue.java index d1fa410d78d..cefa1e28012 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/AbstractCSQueue.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/AbstractCSQueue.java @@ -632,31 +632,42 @@ public abstract class AbstractCSQueue implements CSQueue { if (Resources.lessThan(resourceCalculator, clusterResource, newTotalWithoutReservedResource, currentLimitResource)) { if (LOG.isDebugEnabled()) { - LOG.debug( - "try to use reserved: " + getQueueName() + " usedResources: " - + queueUsage.getUsed() + ", clusterResources: " - + clusterResource + ", reservedResources: " - + resourceCouldBeUnreserved - + ", capacity-without-reserved: " - + newTotalWithoutReservedResource + ", maxLimitCapacity: " - + currentLimitResource); + LOG.debug("try to use reserved: " + getQueueName() + + " usedResources: " + queueUsage.getUsed() + + ", clusterResources: " + clusterResource + + ", reservedResources: " + resourceCouldBeUnreserved + + ", capacity-without-reserved: " + + newTotalWithoutReservedResource + + ", maxLimitCapacity: " + currentLimitResource); } return true; } } + + // Can not assign to this queue if (LOG.isDebugEnabled()) { - LOG.debug(getQueueName() + "Check assign to queue, nodePartition=" - + nodePartition + " usedResources: " + queueUsage - .getUsed(nodePartition) + " clusterResources: " + clusterResource - + " currentUsedCapacity " + Resources - .divide(resourceCalculator, clusterResource, - queueUsage.getUsed(nodePartition), labelManager - .getResourceByLabel(nodePartition, clusterResource)) - + " max-capacity: " + queueCapacities - .getAbsoluteMaximumCapacity(nodePartition) + ")"); + LOG.debug("Failed to assign to queue: " + getQueueName() + + " nodePatrition: " + nodePartition + + ", usedResources: " + queueUsage.getUsed(nodePartition) + + ", clusterResources: " + clusterResource + + ", reservedResources: " + resourceCouldBeUnreserved + + ", maxLimitCapacity: " + currentLimitResource + + ", currTotalUsed:" + usedExceptKillable); } return false; } + if (LOG.isDebugEnabled()) { + LOG.debug("Check assign to queue: " + getQueueName() + + " nodePartition: " + nodePartition + + ", usedResources: " + queueUsage.getUsed(nodePartition) + + ", clusterResources: " + clusterResource + + ", currentUsedCapacity: " + Resources + .divide(resourceCalculator, clusterResource, + queueUsage.getUsed(nodePartition), labelManager + .getResourceByLabel(nodePartition, clusterResource)) + + ", max-capacity: " + queueCapacities + .getAbsoluteMaximumCapacity(nodePartition)); + } return true; } finally { readLock.unlock();