You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by ju...@apache.org on 2012/07/26 22:15:22 UTC
svn commit: r1366181 - in /pig/trunk: CHANGES.txt
test/org/apache/pig/test/TestNewPlanOperatorPlan.java
Author: julien
Date: Thu Jul 26 20:15:21 2012
New Revision: 1366181
URL: http://svn.apache.org/viewvc?rev=1366181&view=rev
Log:
PIG-2842: TestNewPlanOperatorPlan fails when new Configuration() picks up a previous minicluster conf file (julien)
Modified:
pig/trunk/CHANGES.txt
pig/trunk/test/org/apache/pig/test/TestNewPlanOperatorPlan.java
Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1366181&r1=1366180&r2=1366181&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Thu Jul 26 20:15:21 2012
@@ -208,6 +208,8 @@ OPTIMIZATIONS
BUG FIXES
+PIG-2842: TestNewPlanOperatorPlan fails when new Configuration() picks up a previous minicluster conf file (julien)
+
PIG-2827: Unwrap exception swallowing in TOP (haitao.yao via jcoveney)
PIG-2825: StoreFunc signature setting in LogicalPlan broken (jcoveney)
Modified: pig/trunk/test/org/apache/pig/test/TestNewPlanOperatorPlan.java
URL: http://svn.apache.org/viewvc/pig/trunk/test/org/apache/pig/test/TestNewPlanOperatorPlan.java?rev=1366181&r1=1366180&r2=1366181&view=diff
==============================================================================
--- pig/trunk/test/org/apache/pig/test/TestNewPlanOperatorPlan.java (original)
+++ pig/trunk/test/org/apache/pig/test/TestNewPlanOperatorPlan.java Thu Jul 26 20:15:21 2012
@@ -31,6 +31,7 @@ import org.apache.pig.ExecType;
import org.apache.pig.FuncSpec;
import org.apache.pig.backend.hadoop.datastorage.ConfigurationUtil;
import org.apache.pig.builtin.PigStorage;
+import org.apache.pig.builtin.mock.Storage;
import org.apache.pig.data.DataType;
import org.apache.pig.impl.PigContext;
import org.apache.pig.impl.io.FileSpec;
@@ -1527,7 +1528,7 @@ public class TestNewPlanOperatorPlan ext
aschema1.addField(new LogicalSchema.LogicalFieldSchema(
"x", null, DataType.INTEGER));
LOLoad A1 = newLOLoad(new FileSpec("/abc",
- new FuncSpec(DummyLoad.class.getName(), new String[] {"x", "y"})), aschema1, lp1, new Configuration());
+ new FuncSpec(DummyLoad.class.getName(), new String[] {"x", "y"})), aschema1, lp1, conf);
lp1.add(A1);
LogicalExpressionPlan fp1 = new LogicalExpressionPlan();
@@ -1545,7 +1546,7 @@ public class TestNewPlanOperatorPlan ext
LogicalPlan lp2 = new LogicalPlan();
LOLoad A2 = newLOLoad(new FileSpec("/abc",
- new FuncSpec(DummyLoad.class.getName(), new String[] {"x", "z"})), null, lp2, new Configuration());
+ new FuncSpec(DummyLoad.class.getName(), new String[] {"x", "z"})), null, lp2, conf);
lp2.add(A2);
LogicalExpressionPlan fp2 = new LogicalExpressionPlan();