pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject svn commit: r1211659 - in /pig/trunk: CHANGES.txt shims/src/hadoop23/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapBase.java
Date Wed, 07 Dec 2011 21:54:02 GMT
Author: daijy
Date: Wed Dec  7 21:54:02 2011
New Revision: 1211659

URL: http://svn.apache.org/viewvc?rev=1211659&view=rev
Log:
PIG-2402: inIllustrator condition in PigMapReduce is wrong for hadoop 23

Modified:
    pig/trunk/CHANGES.txt
    pig/trunk/shims/src/hadoop23/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapBase.java

Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1211659&r1=1211658&r2=1211659&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Wed Dec  7 21:54:02 2011
@@ -324,6 +324,8 @@ Release 0.9.2 - Unreleased
 
 BUG FIXES
 
+PIG-2402: inIllustrator condition in PigMapReduce is wrong for hadoop 23 (daijy)
+
 PIG-2370: SkewedParitioner results in Kerberos error (daijy)
 
 PIG-2374: streaming regression with dotNext (daijy)

Modified: pig/trunk/shims/src/hadoop23/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapBase.java
URL: http://svn.apache.org/viewvc/pig/trunk/shims/src/hadoop23/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapBase.java?rev=1211659&r1=1211658&r2=1211659&view=diff
==============================================================================
--- pig/trunk/shims/src/hadoop23/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapBase.java
(original)
+++ pig/trunk/shims/src/hadoop23/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapBase.java
Wed Dec  7 21:54:02 2011
@@ -86,6 +86,7 @@ abstract public class PigMapBase extends
               List<Pair<PigNullableWritable, Writable>> output,
               InputSplit split) throws IOException, InterruptedException {
             super(conf, new TaskAttemptID(), null, null, null, new IllustrateDummyReporter(),
split);
+            conf.set("inIllustrator", "true");
             if (output == null)
                 throw new IOException("Null output can not be used");
             this.input = input; this.output = output;
@@ -132,6 +133,6 @@ abstract public class PigMapBase extends
     
     @Override
     public boolean inIllustrator(Context context) {
-        return (context instanceof WrappedMapper.Context);
+        return ((WrappedMapper.Context)context).getConfiguration().get("inIllustrator")!=null;
     }
 }



Mime
View raw message