diff --git a/core/src/main/scala/org/apache/spark/sql/execution/ExistingPlans.scala b/core/src/main/scala/org/apache/spark/sql/execution/ExistingPlans.scala index bcff90dc67..f655456812 100644 --- a/core/src/main/scala/org/apache/spark/sql/execution/ExistingPlans.scala +++ b/core/src/main/scala/org/apache/spark/sql/execution/ExistingPlans.scala @@ -319,6 +319,8 @@ private[sql] final case class ZipPartitionScan(basePlan: CodegenSupport, override def children: Seq[SparkPlan] = basePlan :: withShuffle :: Nil + override def needCopyResult: Boolean = false + override def requiredChildDistribution: Seq[Distribution] = ClusteredDistribution(basePartKeys) :: ClusteredDistribution(otherPartKeys) :: Nil