[PIG-4781] Fix remaining unit failure about "TestCollectedGroup" for spark engine

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: spark-branch
• Component/s: spark
• Assignee: liyunzhang
• Reporter: liyunzhang
• Created: 15/Jan/16 02:33
• Updated: 21/Jun/17 09:18
• Resolved: 26/Feb/16 14:38

Description

in https://builds.apache.org/job/Pig-spark/lastUnsuccessfulBuild/#showFailuresLink, it shows that following unit test fails:
org.apache.pig.test.TestCollectedGroup.testMapsideGroupWithMergeJoin

This fails because currently we use regular join to implement merge join.
the exeception is

Caused by: org.apache.pig.backend.hadoop.executionengine.spark.plan.SparkCompilerException: ERROR 2171: Expected one but found more then one root physical operator in physical physicalPlan.
	at org.apache.pig.backend.hadoop.executionengine.spark.plan.SparkCompiler.visitCollectedGroup(SparkCompiler.java:512)
	at org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POCollectedGroup.visit(POCollectedGroup.java:93)
	at org.apache.pig.backend.hadoop.executionengine.spark.plan.SparkCompiler.compile(SparkCompiler.java:259)
	at org.apache.pig.backend.hadoop.executionengine.spark.plan.SparkCompiler.compile(SparkCompiler.java:240)
	at org.apache.pig.backend.hadoop.executionengine.spark.plan.SparkCompiler.compile(SparkCompiler.java:240)
	at org.apache.pig.backend.hadoop.executionengine.spark.plan.SparkCompiler.compile(SparkCompiler.java:165)
	at org.apache.pig.backend.hadoop.executionengine.spark.SparkLauncher.compile(SparkLauncher.java:425)
	at org.apache.pig.backend.hadoop.executionengine.spark.SparkLauncher.launchPig(SparkLauncher.java:150)
	at org.apache.pig.backend.hadoop.executionengine.HExecutionEngine.launchPig(HExecutionEngine.java:301)
	at org.apache.pig.PigServer.launchPlan(PigServer.java:1390)
	at org.apache.pig.PigServer.executeCompiledLogicalPlan(PigServer.java:1375)
	at org.apache.pig.PigServer.storeEx(PigServer.java:1034)
	... 27 more

After we implement Merge join, this unit test can be fixed.

Issue Links

• relates to: PIG-4810 Implement Merge join for spark engine