tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rbalamo...@apache.org
Subject tez git commit: TEZ-2470. IllegalStateException in ShuffleManager.constructFetcherForHost in tez-0.4.x (rbalamohan)
Date Wed, 20 May 2015 21:55:29 GMT
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 <rbalamohan@apache.org>
Authored: Thu May 21 03:25:56 2015 +0530
Committer: Rajesh Balamohan <rbalamohan@apache.org>
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)) {


Mime
View raw message