pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject svn commit: r1211658 - in /pig/branches/branch-0.10: CHANGES.txt shims/src/hadoop23/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapBase.java
Date Wed, 07 Dec 2011 21:53:25 GMT
Author: daijy
Date: Wed Dec  7 21:53:24 2011
New Revision: 1211658

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

Modified:
    pig/branches/branch-0.10/CHANGES.txt
    pig/branches/branch-0.10/shims/src/hadoop23/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapBase.java

Modified: pig/branches/branch-0.10/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.10/CHANGES.txt?rev=1211658&r1=1211657&r2=1211658&view=diff
==============================================================================
--- pig/branches/branch-0.10/CHANGES.txt (original)
+++ pig/branches/branch-0.10/CHANGES.txt Wed Dec  7 21:53:24 2011
@@ -296,6 +296,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/branches/branch-0.10/shims/src/hadoop23/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapBase.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.10/shims/src/hadoop23/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapBase.java?rev=1211658&r1=1211657&r2=1211658&view=diff
==============================================================================
--- pig/branches/branch-0.10/shims/src/hadoop23/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapBase.java
(original)
+++ pig/branches/branch-0.10/shims/src/hadoop23/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigMapBase.java
Wed Dec  7 21:53:24 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