tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hit...@apache.org
Subject git commit: TEZ-956. Handle zero task vertices correctly on Recovery. (hitesh)
Date Wed, 19 Mar 2014 20:20:13 GMT
Repository: incubator-tez
Updated Branches:
  refs/heads/master 8d4b8e9a5 -> ece53e34a


TEZ-956. Handle zero task vertices correctly on Recovery. (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/ece53e34
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/ece53e34
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/ece53e34

Branch: refs/heads/master
Commit: ece53e34a627a37765da9706e2022d47eb78972d
Parents: 8d4b8e9
Author: Hitesh Shah <hitesh@apache.org>
Authored: Wed Mar 19 13:19:54 2014 -0700
Committer: Hitesh Shah <hitesh@apache.org>
Committed: Wed Mar 19 13:19:54 2014 -0700

----------------------------------------------------------------------
 .../main/java/org/apache/tez/dag/app/dag/impl/VertexImpl.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/ece53e34/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 46c91b1..602bb10 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
@@ -1867,7 +1867,7 @@ public class VertexImpl implements org.apache.tez.dag.app.dag.Vertex,
           } else {
             vertex.tasksNotYetScheduled = false;
             // recover tasks
-            if (vertex.tasks != null) {
+            if (vertex.tasks != null && vertex.numTasks != 0) {
               TaskState taskState = TaskState.KILLED;
               switch (vertex.recoveredState) {
                 case SUCCEEDED:
@@ -2126,7 +2126,7 @@ public class VertexImpl implements org.apache.tez.dag.app.dag.Vertex,
           vertex.tasksNotYetScheduled = false;
           // recover tasks
           assert vertex.tasks.size() == vertex.numTasks;
-          if (vertex.tasks != null) {
+          if (vertex.tasks != null  && vertex.numTasks != 0) {
             TaskState taskState = TaskState.KILLED;
             switch (vertex.recoveredState) {
               case SUCCEEDED:


Mime
View raw message