TEZ-2420. TaskRunner returning before executing the task. (sseth)
Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/7f0b9677 Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/7f0b9677 Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/7f0b9677 Branch: refs/heads/TEZ-2003 Commit: 7f0b9677e788ff8c608a7d64143f7ce7a61517c1 Parents: e4f7ea0 Author: Siddharth Seth <[email protected]> Authored: Wed May 6 17:14:56 2015 -0700 Committer: Siddharth Seth <[email protected]> Committed: Thu Aug 6 01:25:34 2015 -0700 ---------------------------------------------------------------------- TEZ-2003-CHANGES.txt | 1 + .../src/main/java/org/apache/tez/runtime/task/TezTaskRunner.java | 1 + 2 files changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tez/blob/7f0b9677/TEZ-2003-CHANGES.txt ---------------------------------------------------------------------- diff --git a/TEZ-2003-CHANGES.txt b/TEZ-2003-CHANGES.txt index f8a71e8..9b2339f 100644 --- a/TEZ-2003-CHANGES.txt +++ b/TEZ-2003-CHANGES.txt @@ -21,5 +21,6 @@ ALL CHANGES: TEZ-2381. Fixes after rebase 04/28. TEZ-2388. Send dag identifier as part of the fetcher request string. TEZ-2414. LogicalIOProcessorRuntimeTask, RuntimeTask, TezTaskRunner should handle interrupts & carry out necessary cleanups. + TEZ-2420. TaskRunner returning before executing the task. INCOMPATIBLE CHANGES: http://git-wip-us.apache.org/repos/asf/tez/blob/7f0b9677/tez-runtime-internals/src/main/java/org/apache/tez/runtime/task/TezTaskRunner.java ---------------------------------------------------------------------- diff --git a/tez-runtime-internals/src/main/java/org/apache/tez/runtime/task/TezTaskRunner.java b/tez-runtime-internals/src/main/java/org/apache/tez/runtime/task/TezTaskRunner.java index 7238d5e..dd4620a 100644 --- a/tez-runtime-internals/src/main/java/org/apache/tez/runtime/task/TezTaskRunner.java +++ b/tez-runtime-internals/src/main/java/org/apache/tez/runtime/task/TezTaskRunner.java @@ -105,6 +105,7 @@ public class TezTaskRunner implements TezUmbilical, ErrorReporter { Throwable failureCause = null; if (!Thread.currentThread().isInterrupted()) { taskFuture = executor.submit(callable); + } else { return isShutdownRequested(); } try {
