You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by hi...@apache.org on 2014/03/21 01:44:45 UTC
git commit: TEZ-966. Tez AM has invalid state transition error when
datanode is bad. (hitesh)
Repository: incubator-tez
Updated Branches:
refs/heads/master 9bca4c96b -> 3b2c4749a
TEZ-966. Tez AM has invalid state transition error when datanode is bad. (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/3b2c4749
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/3b2c4749
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/3b2c4749
Branch: refs/heads/master
Commit: 3b2c4749a9f735f558144582c40c3bf49565f5dc
Parents: 9bca4c9
Author: Hitesh Shah <hi...@apache.org>
Authored: Thu Mar 20 17:42:54 2014 -0700
Committer: Hitesh Shah <hi...@apache.org>
Committed: Thu Mar 20 17:42:54 2014 -0700
----------------------------------------------------------------------
.../src/main/java/org/apache/tez/dag/app/dag/impl/VertexImpl.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/3b2c4749/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 602bb10..7f94ed7 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
@@ -334,7 +334,8 @@ public class VertexImpl implements org.apache.tez.dag.app.dag.Vertex,
.addTransition
(VertexState.RUNNING,
EnumSet.of(VertexState.RUNNING,
- VertexState.SUCCEEDED, VertexState.TERMINATING, VertexState.FAILED),
+ VertexState.SUCCEEDED, VertexState.TERMINATING, VertexState.FAILED,
+ VertexState.ERROR),
VertexEventType.V_TASK_COMPLETED,
new TaskCompletedTransition())
.addTransition(VertexState.RUNNING, VertexState.TERMINATING,