[SPARK-22238] EnsureStatefulOpPartitioning shouldn't ask for the child RDD before planning is completed

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.3.0
• Fix Version/s: 2.3.0
• Component/s: Structured Streaming
• Target Version/s: 2.3.0
• Assignee: Burak Yavuz
• Reporter: Burak Yavuz
• Created: 10/Oct/17 22:06
• Updated: 16/Sep/18 01:56
• Resolved: 15/Oct/17 00:39

Description

In EnsureStatefulOpPartitioning, we check that the inputRDD to a SparkPlan has the expected partitioning for Streaming Stateful Operators. The problem is that we are not allowed to access this information during planning.

The reason we added that check was because CoalesceExec could actually create RDDs with 0 partitions. We should fix it such that when CoalesceExec says that there is a SinglePartition, there is in fact an inputRDD of 1 partition instead of 0 partitions.

Issue Links

• links to: [Github] Pull Request #19467 (brkyvz)