tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ss...@apache.org
Subject git commit: TEZ-554. VertexImpl should handle V_SOURCE_TASK_ATTEMPT_COMPLETED event at INITED and INITIALIZING state. (sseth)
Date Mon, 14 Oct 2013 06:36:10 GMT
Updated Branches:
  refs/heads/master 305be76dd -> 1d1912202


TEZ-554. VertexImpl should handle V_SOURCE_TASK_ATTEMPT_COMPLETED event
at INITED and INITIALIZING state. (sseth)


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

Branch: refs/heads/master
Commit: 1d19122023fcfa6183d01a14f97823ddb8781677
Parents: 305be76
Author: Siddharth Seth <sseth@apache.org>
Authored: Sun Oct 13 23:35:33 2013 -0700
Committer: Siddharth Seth <sseth@apache.org>
Committed: Sun Oct 13 23:35:33 2013 -0700

----------------------------------------------------------------------
 .../java/org/apache/tez/dag/app/dag/impl/VertexImpl.java     | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/1d191220/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexImpl.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexImpl.java b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexImpl.java
index 80f0a97..f0575f0 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexImpl.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexImpl.java
@@ -227,6 +227,9 @@ public class VertexImpl implements org.apache.tez.dag.app.dag.Vertex,
           .addTransition(VertexState.INITIALIZING, VertexState.INITIALIZING,
               VertexEventType.V_SOURCE_VERTEX_STARTED,
               new SourceVertexStartedTransition())
+          .addTransition(VertexState.INITIALIZING,  VertexState.INITIALIZING,
+              VertexEventType.V_SOURCE_TASK_ATTEMPT_COMPLETED,
+              SOURCE_TASK_ATTEMPT_COMPLETED_EVENT_TRANSITION)
           .addTransition(VertexState.INITIALIZING, VertexState.INITIALIZING,
               VertexEventType.V_ROUTE_EVENT,
               new RouteEventsWhileInitializingTransition())
@@ -242,6 +245,9 @@ public class VertexImpl implements org.apache.tez.dag.app.dag.Vertex,
           .addTransition(VertexState.INITED, VertexState.INITED,
               VertexEventType.V_SOURCE_VERTEX_STARTED,
               new SourceVertexStartedTransition())
+          .addTransition(VertexState.INITIALIZING,  VertexState.INITIALIZING,
+              VertexEventType.V_SOURCE_TASK_ATTEMPT_COMPLETED,
+              SOURCE_TASK_ATTEMPT_COMPLETED_EVENT_TRANSITION)
           .addTransition(VertexState.INITED, VertexState.RUNNING,
               VertexEventType.V_START,
               new StartTransition())
@@ -1483,7 +1489,7 @@ public class VertexImpl implements org.apache.tez.dag.app.dag.Vertex,
   }
 
   /**
-   * Here, the Vertex is being told that one of his source task-attempts
+   * Here, the Vertex is being told that one of it's source task-attempts
    * completed.
    */
   private static class SourceTaskAttemptCompletedEventTransition implements


Mime
View raw message