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:23:58 UTC

svn commit: r1595705 - in /pig/branches/tez: src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java test/org/apache/pig/test/Util.java

Author: cheolsoo
Date: Sun May 18 23:23:57 2014
New Revision: 1595705

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

Modified:
    pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java
    pig/branches/tez/test/org/apache/pig/test/Util.java

Modified: pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java
URL: http://svn.apache.org/viewvc/pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java?rev=1595705&r1=1595704&r2=1595705&view=diff
==============================================================================
--- pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java (original)
+++ pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/HExecutionEngine.java Sun May 18 23:23:57 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/branches/tez/test/org/apache/pig/test/Util.java
URL: http://svn.apache.org/viewvc/pig/branches/tez/test/org/apache/pig/test/Util.java?rev=1595705&r1=1595704&r2=1595705&view=diff
==============================================================================
--- pig/branches/tez/test/org/apache/pig/test/Util.java (original)
+++ pig/branches/tez/test/org/apache/pig/test/Util.java Sun May 18 23:23:57 2014
@@ -65,7 +65,6 @@ import org.apache.pig.backend.executione
 import org.apache.pig.backend.hadoop.datastorage.ConfigurationUtil;
 import org.apache.pig.backend.hadoop.executionengine.HExecutionEngine;
 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;
@@ -1068,7 +1067,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());
     }