Repository: tez Updated Branches: refs/heads/master 7993156c0 -> 7f026a878
TEZ-3748. TaskAttemptImpl State Machine Invalid event: TA_SUBMITTED at KILL_IN_PROGRESS (jeagles) Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/7f026a87 Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/7f026a87 Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/7f026a87 Branch: refs/heads/master Commit: 7f026a878e008e08b0142bc73a6dd89e9d990018 Parents: 7993156 Author: Jonathan Eagles <[email protected]> Authored: Wed May 31 20:38:59 2017 -0500 Committer: Jonathan Eagles <[email protected]> Committed: Wed May 31 20:38:59 2017 -0500 ---------------------------------------------------------------------- .../java/org/apache/tez/dag/app/dag/impl/TaskAttemptImpl.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tez/blob/7f026a87/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TaskAttemptImpl.java ---------------------------------------------------------------------- diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TaskAttemptImpl.java b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TaskAttemptImpl.java index a4c4652..3c8a9b5 100644 --- a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TaskAttemptImpl.java +++ b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TaskAttemptImpl.java @@ -421,6 +421,8 @@ public class TaskAttemptImpl implements TaskAttempt, TaskAttemptStateInternal.KILL_IN_PROGRESS, TaskAttemptStateInternal.KILL_IN_PROGRESS, EnumSet.of(TaskAttemptEventType.TA_STARTED_REMOTELY, + TaskAttemptEventType.TA_SCHEDULE, + TaskAttemptEventType.TA_SUBMITTED, TaskAttemptEventType.TA_CONTAINER_TERMINATED_BY_SYSTEM, TaskAttemptEventType.TA_TEZ_EVENT_UPDATE, TaskAttemptEventType.TA_STATUS_UPDATE, @@ -440,6 +442,8 @@ public class TaskAttemptImpl implements TaskAttempt, TaskAttemptStateInternal.FAIL_IN_PROGRESS, TaskAttemptStateInternal.FAIL_IN_PROGRESS, EnumSet.of(TaskAttemptEventType.TA_STARTED_REMOTELY, + TaskAttemptEventType.TA_SCHEDULE, + TaskAttemptEventType.TA_SUBMITTED, TaskAttemptEventType.TA_CONTAINER_TERMINATED_BY_SYSTEM, TaskAttemptEventType.TA_TEZ_EVENT_UPDATE, TaskAttemptEventType.TA_STATUS_UPDATE, @@ -456,6 +460,7 @@ public class TaskAttemptImpl implements TaskAttempt, TaskAttemptStateInternal.KILLED, EnumSet.of(TaskAttemptEventType.TA_STARTED_REMOTELY, TaskAttemptEventType.TA_SCHEDULE, + TaskAttemptEventType.TA_SUBMITTED, TaskAttemptEventType.TA_CONTAINER_TERMINATED_BY_SYSTEM, TaskAttemptEventType.TA_TEZ_EVENT_UPDATE, TaskAttemptEventType.TA_STATUS_UPDATE, @@ -473,6 +478,7 @@ public class TaskAttemptImpl implements TaskAttempt, TaskAttemptStateInternal.FAILED, EnumSet.of(TaskAttemptEventType.TA_STARTED_REMOTELY, TaskAttemptEventType.TA_SCHEDULE, + TaskAttemptEventType.TA_SUBMITTED, TaskAttemptEventType.TA_CONTAINER_TERMINATED_BY_SYSTEM, TaskAttemptEventType.TA_STATUS_UPDATE, TaskAttemptEventType.TA_DONE, TaskAttemptEventType.TA_FAILED,
