pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From xu...@apache.org
Subject svn commit: r1712207 - /pig/branches/spark/test/org/apache/pig/test/TestPigServerLocal.java
Date Tue, 03 Nov 2015 03:33:18 GMT
Author: xuefu
Date: Tue Nov  3 03:33:18 2015
New Revision: 1712207

URL: http://svn.apache.org/viewvc?rev=1712207&view=rev
Log:
PIG-4661: Fix UT failures in TestPigServerLocal (Xianda via Xuefu)

Modified:
    pig/branches/spark/test/org/apache/pig/test/TestPigServerLocal.java

Modified: pig/branches/spark/test/org/apache/pig/test/TestPigServerLocal.java
URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/test/TestPigServerLocal.java?rev=1712207&r1=1712206&r2=1712207&view=diff
==============================================================================
--- pig/branches/spark/test/org/apache/pig/test/TestPigServerLocal.java (original)
+++ pig/branches/spark/test/org/apache/pig/test/TestPigServerLocal.java Tue Nov  3 03:33:18
2015
@@ -256,6 +256,14 @@ public class TestPigServerLocal {
         if (Util.getLocalTestMode().toString().startsWith("TEZ")) {
             _testSkipParseInRegisterForBatch(false, 6, 4);
             _testSkipParseInRegisterForBatch(true, 3, 1);
+        } else if (Util.getLocalTestMode().toString().startsWith("SPARK")) {
+            // 6 = 4 (Once per registerQuery) + 2 (SortConverter , PigRecordReader)
+            // 4 (Once per registerQuery)
+            _testSkipParseInRegisterForBatch(false, 6, 4);
+
+            // 3 = 1 (registerQuery) + 2 (SortConverter, PigRecordReader)
+            // 1 (registerQuery)
+            _testSkipParseInRegisterForBatch(true, 3, 1);
         } else {
             _testSkipParseInRegisterForBatch(false, 10, 4);
             _testSkipParseInRegisterForBatch(true, 7, 1);



Mime
View raw message