Skip to content

Commit 0177afc

Browse files
authored
fix: Use the loaded Comet extension too (Spark 3.5.8) (#3707)
1 parent 2c71845 commit 0177afc

1 file changed

Lines changed: 34 additions & 2 deletions

File tree

dev/diffs/3.5.8.diff

Lines changed: 34 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,8 @@ index 27ae10b3d59..78e69902dfd 100644
7676
val extensionConfClassNames = sparkContext.getConf.get(StaticSQLConf.SPARK_SESSION_EXTENSIONS)
7777
.getOrElse(Seq.empty)
7878
+ val extensionClassNames = extensionConfClassNames ++ loadCometExtension(sparkContext)
79-
extensionConfClassNames.foreach { extensionConfClassName =>
79+
- extensionConfClassNames.foreach { extensionConfClassName =>
80+
+ extensionClassNames.foreach { extensionConfClassName =>
8081
try {
8182
val extensionConfClass = Utils.classForName(extensionConfClassName)
8283
@@ -1396,4 +1405,12 @@ object SparkSession extends Logging {
@@ -3271,7 +3272,38 @@ index f3be79f9022..b4b1ea8dbc4 100644
32713272
+ IgnoreCometNativeDataFusion("https://github.com/apache/datafusion-comet/issues/3312")) {
32723273

32733274
withTempDir { tempDir =>
3274-
3275+
3276+
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/SparkSessionExtensionSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/SparkSessionExtensionSuite.scala
3277+
index 8b4ac474..3f79f208 100644
3278+
--- a/sql/core/src/test/scala/org/apache/spark/sql/SparkSessionExtensionSuite.scala
3279+
+++ b/sql/core/src/test/scala/org/apache/spark/sql/SparkSessionExtensionSuite.scala
3280+
@@ -223,6 +223,8 @@ class SparkSessionExtensionSuite extends SparkFunSuite with SQLHelper with Adapt
3281+
withSession(extensions) { session =>
3282+
session.conf.set(SQLConf.ADAPTIVE_EXECUTION_ENABLED, true)
3283+
session.conf.set(SQLConf.AUTO_BROADCASTJOIN_THRESHOLD.key, "-1")
3284+
+ // https://github.com/apache/datafusion-comet/issues/1197
3285+
+ session.conf.set("spark.comet.enabled", false)
3286+
assert(session.sessionState.columnarRules.contains(
3287+
MyColumnarRule(PreRuleReplaceAddWithBrokenVersion(), MyPostRule())))
3288+
import session.sqlContext.implicits._
3289+
@@ -281,6 +283,8 @@ class SparkSessionExtensionSuite extends SparkFunSuite with SQLHelper with Adapt
3290+
}
3291+
withSession(extensions) { session =>
3292+
session.conf.set(SQLConf.ADAPTIVE_EXECUTION_ENABLED, enableAQE)
3293+
+ // https://github.com/apache/datafusion-comet/issues/1197
3294+
+ session.conf.set("spark.comet.enabled", false)
3295+
assert(session.sessionState.columnarRules.contains(
3296+
MyColumnarRule(PreRuleReplaceAddWithBrokenVersion(), MyPostRule())))
3297+
import session.sqlContext.implicits._
3298+
@@ -319,6 +323,8 @@ class SparkSessionExtensionSuite extends SparkFunSuite with SQLHelper with Adapt
3299+
val session = SparkSession.builder()
3300+
.master("local[1]")
3301+
.config(COLUMN_BATCH_SIZE.key, 2)
3302+
+ // https://github.com/apache/datafusion-comet/issues/1197
3303+
+ .config("spark.comet.enabled", false)
3304+
.withExtensions { extensions =>
3305+
extensions.injectColumnar(session =>
3306+
MyColumnarRule(PreRuleReplaceAddWithBrokenVersion(), MyPostRule())) }
32753307
diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/SQLQuerySuite.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/SQLQuerySuite.scala
32763308
index 6160c3e5f6c..0956d7d9edc 100644
32773309
--- a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/SQLQuerySuite.scala

0 commit comments

Comments
 (0)