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/constraint/PlacementConstraintsUtil.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/constraint/PlacementConstraintsUtil.java index f47e1d4889..e35d253af8 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/constraint/PlacementConstraintsUtil.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/constraint/PlacementConstraintsUtil.java @@ -149,7 +149,10 @@ private static boolean canSatisfySingleConstraint(ApplicationId applicationId, } else if (currentExp.getTargetType().equals(TargetType.NODE_ATTRIBUTE) && currentExp.getTargetKey().equals(NODE_PARTITION)) { // This is a node partition expression, check it. - canSatisfyNodePartitionConstraintExpresssion(currentExp, schedulerNode); + if (!canSatisfyNodePartitionConstraintExpresssion(currentExp, + schedulerNode)) { + return false; + } } } // return true if all targetExpressions are satisfied