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 2014/06/21 00:35:53 UTC
[15/23] git commit: TEZ-1033. AM hangs during recovery with Tasks
awaiting init event. (hitesh)
TEZ-1033. AM hangs during recovery with Tasks awaiting init event. (hitesh)
Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/279add42
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/279add42
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/279add42
Branch: refs/heads/branch-0.4.1-incubating
Commit: 279add42afcb94f65f0cc970320be46e475cd6e9
Parents: e868b19
Author: Hitesh Shah <hi...@apache.org>
Authored: Wed Apr 9 18:41:04 2014 -0700
Committer: Siddharth Seth <ss...@apache.org>
Committed: Fri Jun 20 15:34:45 2014 -0700
----------------------------------------------------------------------
.../java/org/apache/tez/dag/app/dag/impl/VertexImpl.java | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/279add42/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 a282042..8d61900 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
@@ -2500,8 +2500,13 @@ public class VertexImpl implements org.apache.tez.dag.app.dag.Vertex,
}
if (vertex.startSignalPending) {
- vertex.startVertex(); // Could be modelled as a separate state
- return VertexState.RUNNING;
+ // Trigger a start event to ensure route events are seen before
+ // a start event.
+ LOG.info("Triggering start event for vertex: " + vertex.logIdentifier +
+ " with distanceFromRoot: " + vertex.distanceFromRoot );
+ vertex.eventHandler.handle(new VertexEvent(vertex.vertexId,
+ VertexEventType.V_START));
+ return VertexState.INITED;
}
return vertexState;