fix AQE shuffle copy

Signed-off-by: Yuan Zhou <[email protected]>
oap-project · May 10, 2021 · 39cf3c2 · 39cf3c2
1 parent 6318515
commit 39cf3c2
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...gine/core/src/main/scala/org/apache/spark/sql/execution/ColumnarShuffleExchangeExec.scala b/...gine/core/src/main/scala/org/apache/spark/sql/execution/ColumnarShuffleExchangeExec.scala
@@ -157,7 +157,8 @@ case class ColumnarShuffleExchangeExec(
 
 class ColumnarShuffleExchangeAdaptor(
     override val outputPartitioning: Partitioning,
-    child: SparkPlan  )
+    child: SparkPlan,
+    shuffleOrigin: ShuffleOrigin = ENSURE_REQUIREMENTS)
     extends ShuffleExchangeExec(outputPartitioning, child) {
 
   private[sql] lazy val writeMetrics =