prefix shuffle_writer_type

apache · Aug 13, 2024 · 501ba09 · 501ba09
1 parent f07916a
commit 501ba09
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/gluten-core/src/main/scala/org/apache/spark/sql/execution/ColumnarShuffleExchangeExec.scala b/gluten-core/src/main/scala/org/apache/spark/sql/execution/ColumnarShuffleExchangeExec.scala
@@ -146,7 +146,7 @@ case class ColumnarShuffleExchangeExec(
       if (useSortBasedShuffle) GlutenConfig.GLUTEN_SORT_SHUFFLE_WRITER
       else GlutenConfig.GLUTEN_HASH_SHUFFLE_WRITER
     }
-    super.stringArgs ++ Iterator(s"$shuffleWriterType")
+    super.stringArgs ++ Iterator(s"[shuffle_writer_type=$shuffleWriterType]")
   }
 
   override def doExecute(): RDD[InternalRow] = {