[ 
https://issues.apache.org/jira/browse/PIG-4661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702271#comment-14702271
 ] 

kexianda commented on PIG-4661:
-------------------------------

In spark mode, Storage was initialized in SortConverter, and was initialized 
again in PigRecordReader.

{code}
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);
        }
{code}

PIG-4661.patch is attached. [~mohitsabharwal], would you please help review the 
code? 

Thanks,
Xianda

> Fix UT failures in TestPigServerLocal
> -------------------------------------
>
>                 Key: PIG-4661
>                 URL: https://issues.apache.org/jira/browse/PIG-4661
>             Project: Pig
>          Issue Type: Sub-task
>          Components: spark
>            Reporter: kexianda
>            Assignee: kexianda
>             Fix For: spark-branch
>
>         Attachments: PIG-4661.patch
>
>
> testcase 
> org.apache.pig.test.TestPigServerLocal.testSkipParseInRegisterForBatch failed 
> in spark mode



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to