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:50:38 UTC
svn commit: r1296414 - in /pig/branches/branch-0.9: CHANGES.txt
src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputCommitter.java
Author: daijy
Date: Fri Mar 2 19:50:38 2012
New Revision: 1296414
URL: http://svn.apache.org/viewvc?rev=1296414&view=rev
Log:
PIG-2568: PigOutputCommitter hide exception in commitJob
Modified:
pig/branches/branch-0.9/CHANGES.txt
pig/branches/branch-0.9/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputCommitter.java
Modified: pig/branches/branch-0.9/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.9/CHANGES.txt?rev=1296414&r1=1296413&r2=1296414&view=diff
==============================================================================
--- pig/branches/branch-0.9/CHANGES.txt (original)
+++ pig/branches/branch-0.9/CHANGES.txt Fri Mar 2 19:50:38 2012
@@ -22,6 +22,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/branches/branch-0.9/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputCommitter.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.9/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputCommitter.java?rev=1296414&r1=1296413&r2=1296414&view=diff
==============================================================================
--- pig/branches/branch-0.9/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputCommitter.java (original)
+++ pig/branches/branch-0.9/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigOutputCommitter.java Fri Mar 2 19:50:38 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);
}
}
}