tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bi...@apache.org
Subject git commit: TEZ-621. Incorrect logic in routing to source for broadcast edge (bikas)
Date Fri, 15 Nov 2013 20:23:04 GMT
Updated Branches:
  refs/heads/master 727431fe7 -> ea779ff89


TEZ-621. Incorrect logic in routing to source for broadcast edge (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/ea779ff8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/ea779ff8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/ea779ff8

Branch: refs/heads/master
Commit: ea779ff890e047a91322a5a54fec94d50f7732a0
Parents: 727431f
Author: Bikas Saha <bikas@apache.org>
Authored: Fri Nov 15 12:19:33 2013 -0800
Committer: Bikas Saha <bikas@apache.org>
Committed: Fri Nov 15 12:19:33 2013 -0800

----------------------------------------------------------------------
 .../java/org/apache/tez/dag/app/dag/impl/BroadcastEdgeManager.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/ea779ff8/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/BroadcastEdgeManager.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/BroadcastEdgeManager.java
b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/BroadcastEdgeManager.java
index 21562e7..fedc630 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/BroadcastEdgeManager.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/BroadcastEdgeManager.java
@@ -56,7 +56,7 @@ public class BroadcastEdgeManager extends EdgeManager {
   @Override
   public int routeEventToSourceTasks(int destinationTaskIndex,
       InputReadErrorEvent event) {
-    return destinationTaskIndex;
+    return event.getIndex();
   }
   
   void addAllDestinationTaskIndices(int numDestinationTasks, List<Integer> taskIndeces)
{


Mime
View raw message