Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/21587#discussion_r196652542
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/physical/partitioning.scala
---
@@ -186,9 +180,8 @@ case class RoundRobinPartitioning(numPartitions: Int)
extends Partitioning
case object SinglePartition extends Partitioning {
val numPartitions = 1
- override def satisfies(required: Distribution): Boolean = required match
{
+ override def satisfies0(required: Distribution): Boolean = required
match {
--- End diff --
added in the base class
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
