You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by ss...@apache.org on 2013/10/14 08:36:10 UTC
git commit: TEZ-554. VertexImpl should handle
V_SOURCE_TASK_ATTEMPT_COMPLETED event at INITED and INITIALIZING state.
(sseth)
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 <ss...@apache.org>
Authored: Sun Oct 13 23:35:33 2013 -0700
Committer: Siddharth Seth <ss...@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