Skip to content

Commit 36c2f12

Browse files
committed
feat: Use specified branch of arrow-rs with workaround to invalid offset buffers from Java Arrow
1 parent aa6ddc5 commit 36c2f12

File tree

15 files changed

+662
-528
lines changed

15 files changed

+662
-528
lines changed

common/src/main/scala/org/apache/comet/CometConf.scala

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -130,14 +130,14 @@ object CometConf {
130130
.booleanConf
131131
.createWithDefault(false)
132132

133-
val COMET_COLUMNAR_SHUFFLE_ENABLED: ConfigEntry[Boolean] = conf(
134-
"spark.comet.columnar.shuffle.enabled")
135-
.doc(
136-
"Force Comet to only use columnar shuffle for CometScan and Spark regular operators. " +
137-
"If this is enabled, Comet native shuffle will not be enabled but only Arrow shuffle. " +
138-
"By default, this config is false.")
139-
.booleanConf
140-
.createWithDefault(false)
133+
val COMET_COLUMNAR_SHUFFLE_ENABLED: ConfigEntry[Boolean] =
134+
conf("spark.comet.columnar.shuffle.enabled")
135+
.doc(
136+
"Whether to enable Arrow-based columnar shuffle for Comet and Spark regular operators. " +
137+
"If this is enabled, Comet prefers columnar shuffle than native shuffle. " +
138+
"By default, this config is true.")
139+
.booleanConf
140+
.createWithDefault(true)
141141

142142
val COMET_EXEC_BROADCAST_ENABLED: ConfigEntry[Boolean] =
143143
conf(s"$COMET_EXEC_CONFIG_PREFIX.broadcast.enabled")

0 commit comments

Comments
 (0)