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 <[email protected]> Authored: Thu Oct 29 07:47:02 2015 +0800 Committer: Jeff Zhang <[email protected]> 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();
