You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by zj...@apache.org on 2015/10/29 00:47:12 UTC

tez git commit: TEZ-2900. Ignore V_INPUT_DATA_INFORMATION when vertex is in Failed/Killed/Error (zjffdu)

Repository: tez
Updated Branches:
  refs/heads/master 149a04c28 -> cf8ed2929


TEZ-2900. Ignore V_INPUT_DATA_INFORMATION when vertex is in Failed/Killed/Error (zjffdu)


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

Branch: refs/heads/master
Commit: cf8ed292957c2c4714271baa2ddb712f3014733b
Parents: 149a04c
Author: Jeff Zhang <zj...@apache.org>
Authored: Thu Oct 29 07:47:02 2015 +0800
Committer: Jeff Zhang <zj...@apache.org>
Committed: Thu Oct 29 07:47:02 2015 +0800

----------------------------------------------------------------------
 CHANGES.txt                                                    | 2 ++
 .../main/java/org/apache/tez/dag/app/dag/impl/VertexImpl.java  | 6 +++---
 2 files changed, 5 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/tez/blob/cf8ed292/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 14e2bbe..07a5812 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -6,6 +6,7 @@ Release 0.8.2: Unreleased
 INCOMPATIBLE CHANGES
 
 ALL CHANGES:
+  TEZ-2900. Ignore V_INPUT_DATA_INFORMATION when vertex is in Failed/Killed/Error
   TEZ-2244. PipelinedSorter: Progressive allocation for sort-buffers
   TEZ-2904. Pig can't specify task specific command opts
   TEZ-2888. Make critical path calculation resilient to AM crash
@@ -225,6 +226,7 @@ Release 0.7.1: Unreleased
 INCOMPATIBLE CHANGES
 
 ALL CHANGES
+  TEZ-2900. Ignore V_INPUT_DATA_INFORMATION when vertex is in Failed/Killed/Error
   TEZ-2904. Pig can't specify task specific command opts
   TEZ-2899. Tez UI: DAG getting created with huge horizontal gap in between vertices
   TEZ-2882. Consider improving fetch failure handling

http://git-wip-us.apache.org/repos/asf/tez/blob/cf8ed292/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 af55049..3c6979b 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
@@ -618,7 +618,7 @@ public class VertexImpl implements org.apache.tez.dag.app.dag.Vertex, EventHandl
                   VertexEventType.V_ROOT_INPUT_INITIALIZED,
                   VertexEventType.V_SOURCE_TASK_ATTEMPT_COMPLETED,
                   VertexEventType.V_NULL_EDGE_INITIALIZED,
-                  VertexEventType.V_ROOT_INPUT_FAILED,
+                  VertexEventType.V_INPUT_DATA_INFORMATION,
                   VertexEventType.V_SOURCE_VERTEX_RECOVERED))
 
           // Transitions from KILLED state
@@ -641,7 +641,7 @@ public class VertexImpl implements org.apache.tez.dag.app.dag.Vertex, EventHandl
                   VertexEventType.V_TASK_COMPLETED,
                   VertexEventType.V_ROOT_INPUT_INITIALIZED,
                   VertexEventType.V_NULL_EDGE_INITIALIZED,
-                  VertexEventType.V_ROOT_INPUT_FAILED,
+                  VertexEventType.V_INPUT_DATA_INFORMATION,
                   VertexEventType.V_SOURCE_VERTEX_RECOVERED))
 
           // No transitions from INTERNAL_ERROR state. Ignore all.
@@ -662,7 +662,7 @@ public class VertexImpl implements org.apache.tez.dag.app.dag.Vertex, EventHandl
                   VertexEventType.V_INTERNAL_ERROR,
                   VertexEventType.V_ROOT_INPUT_INITIALIZED,
                   VertexEventType.V_NULL_EDGE_INITIALIZED,
-                  VertexEventType.V_ROOT_INPUT_FAILED,
+                  VertexEventType.V_INPUT_DATA_INFORMATION,
                   VertexEventType.V_SOURCE_VERTEX_RECOVERED))
           // create the topology tables
           .installTopology();