Repository: tez Updated Branches: refs/heads/branch-0.9 5412033cd -> 8cb99c507
TEZ-3980: ShuffleRunner: the wake loop needs to check for shutdown (Gopal V, reviewed by Gunther Hagleitner) (cherry picked from commit a37a367b400dd5b1cab22b35a47fb664055f3df6) Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/8cb99c50 Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/8cb99c50 Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/8cb99c50 Branch: refs/heads/branch-0.9 Commit: 8cb99c507031f9f4d5a2ea6a11401225da22e018 Parents: 5412033 Author: Gopal V <[email protected]> Authored: Mon Aug 27 20:37:27 2018 -0700 Committer: Jason Lowe <[email protected]> Committed: Wed Aug 29 11:07:03 2018 -0500 ---------------------------------------------------------------------- .../tez/runtime/library/common/shuffle/impl/ShuffleManager.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tez/blob/8cb99c50/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/ShuffleManager.java ---------------------------------------------------------------------- diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/ShuffleManager.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/ShuffleManager.java index 0a0286e..5f3693f 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/ShuffleManager.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/ShuffleManager.java @@ -325,6 +325,9 @@ public class ShuffleManager implements FetcherCallback { && numCompletedInputs.get() < numInputs) { inputContext.notifyProgress(); boolean ret = wakeLoop.await(1000, TimeUnit.MILLISECONDS); + if (isShutdown.get()) { + break; + } } } finally { lock.unlock();
