Author: rding Date: Sat May 7 00:12:55 2011 New Revision: 1100419 URL: http://svn.apache.org/viewvc?rev=1100419&view=rev Log: PIG-2033: Pig returns sucess for the failed Pig script
Modified: pig/trunk/CHANGES.txt pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java Modified: pig/trunk/CHANGES.txt URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1100419&r1=1100418&r2=1100419&view=diff ============================================================================== --- pig/trunk/CHANGES.txt (original) +++ pig/trunk/CHANGES.txt Sat May 7 00:12:55 2011 @@ -557,6 +557,8 @@ PIG-1309: Map-side Cogroup (ashutoshc) BUG FIXES +PIG-2033: Pig returns sucess for the failed Pig script (rding) + PIG-1993: PigStorageSchema throw NPE with ColumnPruning (daijy) PIG-1935: New logical plan: Should not push up filter in front of Bincond (daijy) Modified: pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java?rev=1100419&r1=1100418&r2=1100419&view=diff ============================================================================== --- pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java (original) +++ pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java Sat May 7 00:12:55 2011 @@ -354,6 +354,10 @@ public class MapReduceLauncher extends L // stats collection is done, log the results PigStatsUtil.stopCollection(true); + // PigStatsUtil.stopCollection also computes the return code based on + // total jobs to run, jobs successful and jobs failed + failed = failed || !PigStats.get().isSuccessful(); + Map<Enum, Long> warningAggMap = new HashMap<Enum, Long>(); if (succJobs != null) {