You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by dv...@apache.org on 2012/04/15 17:25:12 UTC
svn commit: r1326362 - in /pig/branches/branch-0.9: CHANGES.txt
src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MRCompiler.java
Author: dvryaboy
Date: Sun Apr 15 15:25:12 2012
New Revision: 1326362
URL: http://svn.apache.org/viewvc?rev=1326362&view=rev
Log:
Rolling back PIG-2652
Modified:
pig/branches/branch-0.9/CHANGES.txt
pig/branches/branch-0.9/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MRCompiler.java
Modified: pig/branches/branch-0.9/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.9/CHANGES.txt?rev=1326362&r1=1326361&r2=1326362&view=diff
==============================================================================
--- pig/branches/branch-0.9/CHANGES.txt (original)
+++ pig/branches/branch-0.9/CHANGES.txt Sun Apr 15 15:25:12 2012
@@ -28,8 +28,6 @@ PIG-2619: HBaseStorage constructs a Scan
BUG FIXES
-PIG-2652: Skew join and order by don't trigger reducer estimation (billgraham via dvryaboy)
-
PIG-2642: StoreMetadata.storeSchema can't access files in the output directory (Hadoop 0.23) (thw via daijy)
PIG-2621: Documentation inaccurate regarding Pig Properties in trunk (prkommireddi via daijy)
Modified: pig/branches/branch-0.9/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MRCompiler.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.9/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MRCompiler.java?rev=1326362&r1=1326361&r2=1326362&view=diff
==============================================================================
--- pig/branches/branch-0.9/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MRCompiler.java (original)
+++ pig/branches/branch-0.9/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MRCompiler.java Sun Apr 15 15:25:12 2012
@@ -2491,8 +2491,8 @@ public class MRCompiler extends PhyPlanV
val = pigContext.defaultParallel;
if (val<=0)
val = eng.getJobConf().getNumReduceTasks();
- if (val<=1)
- val = -1;
+ if (val<=0)
+ val = 1;
} catch (Exception e) {
int errCode = 6015;
String msg = "Problem getting the default number of reduces from the Job Client.";