Skip to content

Commit

Permalink
test: fix ClassNotFoundException for Hive tests (#499)
Browse files Browse the repository at this point in the history
## Rationale for this change

To fix `java.lang.ClassNotFoundException: org.apache.spark.CometSparkSessionExtensions` in Hive tests

## What changes are included in this PR?

fixed diffs

## How are these changes tested?

existing tests
  • Loading branch information
kazuyukitanimura authored May 31, 2024
1 parent 1f81c38 commit 6ea5a42
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion dev/diffs/3.4.2.diff
Original file line number Diff line number Diff line change
Expand Up @@ -2526,7 +2526,7 @@ index 07361cfdce9..25b0dc3ef7e 100644
+ val v = System.getenv("ENABLE_COMET")
+ if (v != null && v.toBoolean) {
+ conf
+ .set("spark.sql.extensions", "org.apache.spark.CometSparkSessionExtensions")
+ .set("spark.sql.extensions", "org.apache.comet.CometSparkSessionExtensions")
+ .set("spark.comet.enabled", "true")
+
+ val v = System.getenv("ENABLE_COMET_SCAN_ONLY")
Expand Down
2 changes: 1 addition & 1 deletion dev/diffs/3.4.3.diff
Original file line number Diff line number Diff line change
Expand Up @@ -2535,7 +2535,7 @@ index 07361cfdce9..25b0dc3ef7e 100644
+ val v = System.getenv("ENABLE_COMET")
+ if (v != null && v.toBoolean) {
+ conf
+ .set("spark.sql.extensions", "org.apache.spark.CometSparkSessionExtensions")
+ .set("spark.sql.extensions", "org.apache.comet.CometSparkSessionExtensions")
+ .set("spark.comet.enabled", "true")
+
+ val v = System.getenv("ENABLE_COMET_SCAN_ONLY")
Expand Down

0 comments on commit 6ea5a42

Please sign in to comment.