You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by xu...@apache.org on 2015/11/03 04:33:18 UTC
svn commit: r1712207 -
/pig/branches/spark/test/org/apache/pig/test/TestPigServerLocal.java
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);