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/fair/FSLeafQueue.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSLeafQueue.java index 5eafa522f72..af366ec55dc 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSLeafQueue.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSLeafQueue.java @@ -352,9 +352,19 @@ public Resource assignContainer(FSSchedulerNode node) { continue; } assigned = sched.assignContainer(node); - if (!assigned.equals(none())) { - LOG.debug("Assigned container in queue:{} container:{}", - getName(), assigned); + + boolean isContainerAssignedOrReserved = !assigned.equals(none()); + boolean isContainerReserved = + assigned.equals(FairScheduler.CONTAINER_RESERVED); + + // check if an assignment or a reservation was made. + if (isContainerAssignedOrReserved) { + // only log container assignment if there was an actual allocation, + // not a reservation. + if (!isContainerReserved && LOG.isDebugEnabled()) { + LOG.debug("Assigned container in queue:{} container:{}", + getName(), assigned); + } break; } }