From cafd0604a14e7a10681a9f9c109ad47bfd5a543d Mon Sep 17 00:00:00 2001 From: ymahajan Date: Thu, 17 May 2018 19:08:09 -0700 Subject: [PATCH] Addressing precheckin failures --- .../scala/org/apache/spark/sql/execution/ExistingPlans.scala | 2 ++ 1 file changed, 2 insertions(+) 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