You are viewing a plain text version of this content. The canonical link for it is here.
Posted to mapreduce-commits@hadoop.apache.org by am...@apache.org on 2010/09/07 05:46:29 UTC
svn commit: r993210 - in /hadoop/mapreduce/trunk: CHANGES.txt
src/contrib/gridmix/src/java/org/apache/hadoop/mapred/gridmix/Statistics.java
Author: amareshwari
Date: Tue Sep 7 03:46:29 2010
New Revision: 993210
URL: http://svn.apache.org/viewvc?rev=993210&view=rev
Log:
MAPREDUCE-1975. Fixes unnecessary InterruptedException log in gridmix. Contributed by Ravi Gummadi
Modified:
hadoop/mapreduce/trunk/CHANGES.txt
hadoop/mapreduce/trunk/src/contrib/gridmix/src/java/org/apache/hadoop/mapred/gridmix/Statistics.java
Modified: hadoop/mapreduce/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/CHANGES.txt?rev=993210&r1=993209&r2=993210&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/CHANGES.txt (original)
+++ hadoop/mapreduce/trunk/CHANGES.txt Tue Sep 7 03:46:29 2010
@@ -280,6 +280,9 @@ Trunk (unreleased changes)
MAPREDUCE-2046. Fixes CombineFileInputFormat to allow splits with size
less than DFS block size. (dhruba borthakur via amareshwari)
+ MAPREDUCE-1975. Fixes unnecessary InterruptedException log in gridmix.
+ (Ravi Gummadi via amareshwari)
+
Release 0.21.0 - Unreleased
INCOMPATIBLE CHANGES
Modified: hadoop/mapreduce/trunk/src/contrib/gridmix/src/java/org/apache/hadoop/mapred/gridmix/Statistics.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/contrib/gridmix/src/java/org/apache/hadoop/mapred/gridmix/Statistics.java?rev=993210&r1=993209&r2=993210&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/contrib/gridmix/src/java/org/apache/hadoop/mapred/gridmix/Statistics.java (original)
+++ hadoop/mapreduce/trunk/src/contrib/gridmix/src/java/org/apache/hadoop/mapred/gridmix/Statistics.java Tue Sep 7 03:46:29 2010
@@ -189,9 +189,10 @@ public class Statistics implements Compo
try {
jobCompleted.await(jtPollingInterval, TimeUnit.MILLISECONDS);
} catch (InterruptedException ie) {
- LOG.error(
- "Statistics interrupt while waiting for polling " + ie.getCause(),
- ie);
+ if (!shutdown) {
+ LOG.error("Statistics interrupt while waiting for completion of "
+ + "a job.", ie);
+ }
return;
} finally {
lock.unlock();