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