[
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)
