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/df91ad58 Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/df91ad58 Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/df91ad58 Branch: refs/heads/TEZ-2003 Commit: df91ad5832ae0345a80d2ec16bfc9d114805117e Parents: 6dabd8e Author: Siddharth Seth <[email protected]> Authored: Wed May 6 17:14:56 2015 -0700 Committer: Siddharth Seth <[email protected]> Committed: Fri Aug 21 18:13:54 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/df91ad58/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/df91ad58/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 {
