You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by ch...@apache.org on 2014/05/19 01:25:14 UTC

svn commit: r1595706 - in /pig/trunk: CHANGES.txt src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java test/org/apache/pig/test/Util.java

Author: cheolsoo
Date: Sun May 18 23:25:14 2014
New Revision: 1595706

URL: http://svn.apache.org/r1595706
Log:
PIG-3942: Util.buildPp() is incompatible with Non-MR execution engine (cheolsoo)

Modified:
    pig/trunk/CHANGES.txt
    pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java
    pig/trunk/test/org/apache/pig/test/Util.java

Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1595706&r1=1595705&r2=1595706&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Sun May 18 23:25:14 2014
@@ -133,6 +133,8 @@ PIG-3882: Multiquery off mode execution 
  
 BUG FIXES
 
+PIG-3942: Util.buildPp() is incompatible with Non-MR execution engine (cheolsoo)
+
 PIG-3902: PigServer creates cycle (thedatachef via cheolsoo)
 
 PIG-3930: "java.io.IOException: Cannot initialize Cluster" in local mode with hadoopversion=23 dependencies (jira.shegalov via cheolsoo)

Modified: pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java?rev=1595706&r1=1595705&r2=1595706&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java (original)
+++ pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java Sun May 18 23:25:14 2014
@@ -221,7 +221,6 @@ public abstract class HExecutionEngine i
         }
     }
 
-    @SuppressWarnings("unchecked")
     public PhysicalPlan compile(LogicalPlan plan, Properties properties) throws FrontendException {
         if (plan == null) {
             int errCode = 2041;

Modified: pig/trunk/test/org/apache/pig/test/Util.java
URL: http://svn.apache.org/viewvc/pig/trunk/test/org/apache/pig/test/Util.java?rev=1595706&r1=1595705&r2=1595706&view=diff
==============================================================================
--- pig/trunk/test/org/apache/pig/test/Util.java (original)
+++ pig/trunk/test/org/apache/pig/test/Util.java Sun May 18 23:25:14 2014
@@ -66,7 +66,6 @@ import org.apache.pig.ResourceSchema.Res
 import org.apache.pig.backend.executionengine.ExecException;
 import org.apache.pig.backend.hadoop.datastorage.ConfigurationUtil;
 import org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRCompiler;
-import org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRExecutionEngine;
 import org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher;
 import org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.MROperPlan;
 import org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PhysicalPlan;
@@ -1059,7 +1058,7 @@ public class Util {
     throws Exception {
         LogicalPlan lp = buildLp( pigServer, query );
         lp.optimize(pigServer.getPigContext());
-        return ((MRExecutionEngine)pigServer.getPigContext().getExecutionEngine()).compile(lp, 
+        return ((HExecutionEngine)pigServer.getPigContext().getExecutionEngine()).compile(lp, 
                 pigServer.getPigContext().getProperties());
     }