From 501ba0903f6b29da308a66d7330055c3ba6af633 Mon Sep 17 00:00:00 2001
From: Rong Ma <rong.ma@intel.com>
Date: Tue, 13 Aug 2024 07:19:50 +0000
Subject: [PATCH] prefix shuffle_writer_type

---
 .../spark/sql/execution/ColumnarShuffleExchangeExec.scala       | 2 +-
 1 file changed, 1 insertion(+), 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
index d5d3a32839eb..f12e3ae0b33e 100644
--- 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] = {