You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by cu...@apache.org on 2006/05/24 01:25:10 UTC
svn commit: r409024 - in /lucene/hadoop/trunk: CHANGES.txt
src/java/org/apache/hadoop/mapred/ReduceTask.java
Author: cutting
Date: Tue May 23 16:25:10 2006
New Revision: 409024
URL: http://svn.apache.org/viewvc?rev=409024&view=rev
Log:
HADOOP-247. Fix sort progress to better handle exceptions. Contributed by Mahadev.
Modified:
lucene/hadoop/trunk/CHANGES.txt
lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/ReduceTask.java
Modified: lucene/hadoop/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/CHANGES.txt?rev=409024&r1=409023&r2=409024&view=diff
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Tue May 23 16:25:10 2006
@@ -55,6 +55,9 @@
14. HADOOP-205. Incorporate pending tasks into tasktracker load
calculations. (Mahadev Konar via cutting)
+15. HADOOP-247. Fix sort progress to better handle exceptions.
+ (Mahadev Konar via cutting)
+
Release 0.2.1 - 2006-05-12
Modified: lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/ReduceTask.java
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/ReduceTask.java?rev=409024&r1=409023&r2=409024&view=diff
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/ReduceTask.java (original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/ReduceTask.java Tue May 23 16:25:10 2006
@@ -229,9 +229,12 @@
reportProgress(umbilical);
Thread.sleep(PROGRESS_INTERVAL);
} catch (InterruptedException e) {
- continue;
+ return;
} catch (Throwable e) {
- return;
+ System.out.println("Thread Exception in " +
+ "reporting sort progress\n" +
+ StringUtils.stringifyException(e));
+ continue;
}
}
}