@@ -576,9 +576,7 @@ object GlutenConfig {
576
576
val SPARK_REDACTION_REGEX = " spark.redaction.regex"
577
577
val SPARK_SHUFFLE_FILE_BUFFER = " spark.shuffle.file.buffer"
578
578
val SPARK_UNSAFE_SORTER_SPILL_READER_BUFFER_SIZE = " spark.unsafe.sorter.spill.reader.buffer.size"
579
- val SPARK_UNSAFE_SORTER_SPILL_READER_BUFFER_SIZE_DEFAULT : Int = 1024 * 1024
580
579
val SPARK_SHUFFLE_SPILL_DISK_WRITE_BUFFER_SIZE = " spark.shuffle.spill.diskWriteBufferSize"
581
- val SPARK_SHUFFLE_SPILL_DISK_WRITE_BUFFER_SIZE_DEFAULT : Int = 1024 * 1024
582
580
val SPARK_SHUFFLE_SPILL_COMPRESS = " spark.shuffle.spill.compress"
583
581
val SPARK_SHUFFLE_SPILL_COMPRESS_DEFAULT : Boolean = true
584
582
@@ -650,16 +648,26 @@ object GlutenConfig {
650
648
(
651
649
GLUTEN_COLUMNAR_TO_ROW_MEM_THRESHOLD .key,
652
650
GLUTEN_COLUMNAR_TO_ROW_MEM_THRESHOLD .defaultValue.get.toString),
653
- (
654
- SPARK_UNSAFE_SORTER_SPILL_READER_BUFFER_SIZE ,
655
- SPARK_UNSAFE_SORTER_SPILL_READER_BUFFER_SIZE_DEFAULT .toString),
656
- (
657
- SPARK_SHUFFLE_SPILL_DISK_WRITE_BUFFER_SIZE ,
658
- SPARK_SHUFFLE_SPILL_DISK_WRITE_BUFFER_SIZE_DEFAULT .toString),
659
651
(SPARK_SHUFFLE_SPILL_COMPRESS , SPARK_SHUFFLE_SPILL_COMPRESS_DEFAULT .toString)
660
652
)
661
653
keyWithDefault.forEach(e => nativeConfMap.put(e._1, conf.getOrElse(e._1, e._2)))
662
654
655
+ conf
656
+ .get(SPARK_UNSAFE_SORTER_SPILL_READER_BUFFER_SIZE )
657
+ .foreach(
658
+ v =>
659
+ nativeConfMap
660
+ .put(
661
+ SPARK_UNSAFE_SORTER_SPILL_READER_BUFFER_SIZE ,
662
+ JavaUtils .byteStringAs(v, ByteUnit .BYTE ).toString))
663
+ conf
664
+ .get(SPARK_SHUFFLE_SPILL_DISK_WRITE_BUFFER_SIZE )
665
+ .foreach(
666
+ v =>
667
+ nativeConfMap
668
+ .put(
669
+ SPARK_SHUFFLE_SPILL_DISK_WRITE_BUFFER_SIZE ,
670
+ JavaUtils .byteStringAs(v, ByteUnit .BYTE ).toString))
663
671
conf
664
672
.get(SPARK_SHUFFLE_FILE_BUFFER )
665
673
.foreach(
0 commit comments