You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by da...@apache.org on 2012/03/02 20:51:41 UTC
svn commit: r1296416 - in /pig/trunk: CHANGES.txt
src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputCommitter.java
Author: daijy
Date: Fri Mar 2 19:51:40 2012
New Revision: 1296416
URL: http://svn.apache.org/viewvc?rev=1296416&view=rev
Log:
PIG-2568: PigOutputCommitter hide exception in commitJob
Modified:
pig/trunk/CHANGES.txt
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputCommitter.java
Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1296416&r1=1296415&r2=1296416&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Fri Mar 2 19:51:40 2012
@@ -423,6 +423,8 @@ Release 0.9.3 - Unreleased
BUG FIXES
+PIG-2568: PigOutputCommitter hide exception in commitJob (daijy)
+
PIG-2564: Build fails - Hadoop 0.23.1-SNAPSHOT no longer available (thw via daijy)
PIG-2535: Bug in new logical plan results in no output for join (daijy)
Modified: pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputCommitter.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputCommitter.java?rev=1296416&r1=1296415&r2=1296416&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputCommitter.java (original)
+++ pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputCommitter.java Fri Mar 2 19:51:40 2012
@@ -184,8 +184,7 @@ public class PigOutputCommitter extends
m.setAccessible(true);
m.invoke(mapCommitter.first, updatedContext);
} catch (Exception e) {
- // Should not happen
- assert(false);
+ throw new IOException(e);
}
}
}
@@ -201,8 +200,7 @@ public class PigOutputCommitter extends
m.setAccessible(true);
m.invoke(reduceCommitter.first, updatedContext);
} catch (Exception e) {
- // Should not happen
- assert(false);
+ throw new IOException(e);
}
}
}