Repository: tez Updated Branches: refs/heads/branch-0.4 cb2a3c94a -> 75f786d39
TEZ-2470. IllegalStateException in ShuffleManager.constructFetcherForHost in tez-0.4.x (rbalamohan) Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/75f786d3 Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/75f786d3 Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/75f786d3 Branch: refs/heads/branch-0.4 Commit: 75f786d39f366e2b01bcc89922f1a2ac1e80a156 Parents: cb2a3c9 Author: Rajesh Balamohan <[email protected]> Authored: Thu May 21 03:25:56 2015 +0530 Committer: Rajesh Balamohan <[email protected]> Committed: Thu May 21 03:25:56 2015 +0530 ---------------------------------------------------------------------- CHANGES.txt | 1 + .../tez/runtime/library/shuffle/common/impl/ShuffleManager.java | 1 + 2 files changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tez/blob/75f786d3/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index 7add3fe..3366777 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -6,6 +6,7 @@ Release 0.4.2: Unreleased ALL CHANGES TEZ-1631. Session dag submission timeout can result in duplicate DAG submissions + TEZ-2470. IllegalStateException in ShuffleManager.constructFetcherForHost in tez-0.4.x Release 0.4.1-incubating: 2014-06-30 http://git-wip-us.apache.org/repos/asf/tez/blob/75f786d3/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/shuffle/common/impl/ShuffleManager.java ---------------------------------------------------------------------- diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/shuffle/common/impl/ShuffleManager.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/shuffle/common/impl/ShuffleManager.java index 050c0c0..1028203 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/shuffle/common/impl/ShuffleManager.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/shuffle/common/impl/ShuffleManager.java @@ -316,6 +316,7 @@ public class ShuffleManager implements FetcherCallback { // Avoid adding attempts which have already completed. if (completedInputSet.contains(input.getInputIdentifier())) { inputIter.remove(); + continue; } // Avoid adding attempts which have been marked as OBSOLETE if (obsoletedInputs.contains(input)) {
