tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bi...@apache.org
Subject git commit: TEZ-275. Test failure in TestDAGImpl (bikas)
Date Fri, 28 Jun 2013 23:01:43 GMT
Updated Branches:
  refs/heads/master 81c0ded1e -> 6ca6af383


TEZ-275. Test failure in TestDAGImpl (bikas)


Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/6ca6af38
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/6ca6af38
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/6ca6af38

Branch: refs/heads/master
Commit: 6ca6af3830be442cab941368146c82de8878c7a4
Parents: 81c0ded
Author: Bikas Saha <bikas@apache.org>
Authored: Fri Jun 28 15:58:04 2013 -0700
Committer: Bikas Saha <bikas@apache.org>
Committed: Fri Jun 28 15:58:04 2013 -0700

----------------------------------------------------------------------
 .../src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/6ca6af38/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java
index 30b48ac..23bfbd1 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java
@@ -851,7 +851,7 @@ public class DAGImpl implements org.apache.tez.dag.app.dag.DAG,
             outVertices.isEmpty() || 
             (outVertices.size() == 1 && 
               outVertices.values().iterator().next().getConnectionPattern() 
-              != EdgeProperty.ConnectionPattern.BIPARTITE))) {
+              == EdgeProperty.ConnectionPattern.BIPARTITE))) {
           // more than 1 output OR single output is not bipartite
           isMRR = false;
           break;          
@@ -860,7 +860,7 @@ public class DAGImpl implements org.apache.tez.dag.app.dag.DAG,
             inVertices.isEmpty() || 
             (inVertices.size() == 1 && 
               inVertices.values().iterator().next().getConnectionPattern() 
-              != EdgeProperty.ConnectionPattern.BIPARTITE))) {
+              == EdgeProperty.ConnectionPattern.BIPARTITE))) {
           // more than 1 output OR single output is not bipartite
           isMRR = false;
           break;          


Mime
View raw message