You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by zl...@apache.org on 2017/04/07 01:48:08 UTC
svn commit: r1790493 - in /pig/branches/spark/test: excluded-tests-spark
org/apache/pig/pigunit/PigTest.java
Author: zly
Date: Fri Apr 7 01:48:07 2017
New Revision: 1790493
URL: http://svn.apache.org/viewvc?rev=1790493&view=rev
Log:
PIG-5136:Fix TestPigTest unit test in Spark mode(Liyun)
Modified:
pig/branches/spark/test/excluded-tests-spark
pig/branches/spark/test/org/apache/pig/pigunit/PigTest.java
Modified: pig/branches/spark/test/excluded-tests-spark
URL: http://svn.apache.org/viewvc/pig/branches/spark/test/excluded-tests-spark?rev=1790493&r1=1790492&r2=1790493&view=diff
==============================================================================
--- pig/branches/spark/test/excluded-tests-spark (original)
+++ pig/branches/spark/test/excluded-tests-spark Fri Apr 7 01:48:07 2017
@@ -7,5 +7,3 @@
**/TestAvroStorage.java
#TODO: PIG-5135 fix for Spark mode
**/TestOrcStoragePushdown.java
-#TODO: PIG-5136 fix for Spark mode
-**/TestPigTest.java
Modified: pig/branches/spark/test/org/apache/pig/pigunit/PigTest.java
URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/pigunit/PigTest.java?rev=1790493&r1=1790492&r2=1790493&view=diff
==============================================================================
--- pig/branches/spark/test/org/apache/pig/pigunit/PigTest.java (original)
+++ pig/branches/spark/test/org/apache/pig/pigunit/PigTest.java Fri Apr 7 01:48:07 2017
@@ -142,6 +142,12 @@ public class PigTest {
} else if (System.getProperties().getProperty(EXEC_CLUSTER).equalsIgnoreCase("tez_local")) {
LOG.info("Using tez local mode");
execType = ExecTypeProvider.fromString("tez_local");
+ } else if (System.getProperties().getProperty(EXEC_CLUSTER).equalsIgnoreCase("spark")) {
+ LOG.info("Using spark cluster mode");
+ execType = ExecTypeProvider.fromString("spark");
+ } else if (System.getProperties().getProperty(EXEC_CLUSTER).equalsIgnoreCase("spark_local")) {
+ LOG.info("Using spark local cluster mode");
+ execType = ExecTypeProvider.fromString("spark_local");
} else {
LOG.info("Using default local mode");
}