diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSAppAttempt.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSAppAttempt.java index 45d5bba..c64d0a0 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSAppAttempt.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSAppAttempt.java @@ -606,6 +606,14 @@ private Resource assignContainer(FSSchedulerNode node, boolean reserved) { if (rackLocalRequest != null && rackLocalRequest.getNumContainers() != 0 && localRequest != null && localRequest.getNumContainers() != 0) { + if (LOG.isDebugEnabled()) { + LOG.debug("Assign container on " + node.getNodeName() + + " node, requestType:" + NodeType.NODE_LOCAL + + ", allowedLocality:" + allowedLocality + + ", schedulingOpportunities:" + + this.getSchedulingOpportunities(priority) + ", priority:" + + priority + ", app attempt id:" + this.attemptId); + } return assignContainer(node, localRequest, NodeType.NODE_LOCAL, reserved); } @@ -617,6 +625,14 @@ private Resource assignContainer(FSSchedulerNode node, boolean reserved) { if (rackLocalRequest != null && rackLocalRequest.getNumContainers() != 0 && (allowedLocality.equals(NodeType.RACK_LOCAL) || allowedLocality.equals(NodeType.OFF_SWITCH))) { + if (LOG.isDebugEnabled()) { + LOG.debug("Assign container on " + node.getNodeName() + + " node, requestType:" + NodeType.RACK_LOCAL + + ", allowedLocality:" + allowedLocality + + ", schedulingOpportunities:" + + this.getSchedulingOpportunities(priority) + ", priority:" + + priority + ", app attempt id:" + this.attemptId); + } return assignContainer(node, rackLocalRequest, NodeType.RACK_LOCAL, reserved); } @@ -631,10 +647,26 @@ private Resource assignContainer(FSSchedulerNode node, boolean reserved) { offSwitchRequest.getNumContainers() != 0) { if (!hasNodeOrRackLocalRequests(priority) || allowedLocality.equals(NodeType.OFF_SWITCH)) { + if (LOG.isDebugEnabled()) { + LOG.debug("Assign assign container on " + node.getNodeName() + + " node, requestType:" + NodeType.OFF_SWITCH + + ", allowedLocality:" + allowedLocality + + ", schedulingOpportunities:" + + this.getSchedulingOpportunities(priority) + ", priority:" + + priority + ", app attempt id:" + this.attemptId); + } return assignContainer( node, offSwitchRequest, NodeType.OFF_SWITCH, reserved); } } + + if (LOG.isDebugEnabled()) { + LOG.debug("Can't assign container on " + node.getNodeName() + + " node, allowedLocality:" + allowedLocality + + ", schedulingOpportunities:" + + this.getSchedulingOpportunities(priority) + ", priority:" + + priority + ", app attempt id:" + this.attemptId); + } } } return Resources.none();