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());
}