You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by ww...@apache.org on 2019/04/26 05:17:13 UTC

[hadoop] branch branch-3.1 updated: YARN-9307. node_partitions constraint does not work. Contributed by kyungwan nam.

This is an automated email from the ASF dual-hosted git repository.

wwei pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/hadoop.git


The following commit(s) were added to refs/heads/branch-3.1 by this push:
     new 94a895b  YARN-9307. node_partitions constraint does not work. Contributed by kyungwan nam.
94a895b is described below

commit 94a895b94fc4c1e9d887974039172755c16560b2
Author: Weiwei Yang <ww...@apache.org>
AuthorDate: Fri Apr 26 13:16:43 2019 +0800

    YARN-9307. node_partitions constraint does not work. Contributed by kyungwan nam.
---
 .../scheduler/constraint/PlacementConstraintsUtil.java               | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

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 f47e1d4..e35d253 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 @@ public final class PlacementConstraintsUtil {
       } 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


---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org