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