You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by jl...@apache.org on 2018/08/29 16:10:29 UTC
tez git commit: TEZ-3980: ShuffleRunner: the wake loop needs to check
for shutdown (Gopal V, reviewed by Gunther Hagleitner)
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 <go...@apache.org>
Authored: Mon Aug 27 20:37:27 2018 -0700
Committer: Jason Lowe <jl...@apache.org>
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();