This is an automated email from the ASF dual-hosted git repository.

kazuyukitanimura pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion-comet.git


The following commit(s) were added to refs/heads/main by this push:
     new 6ea5a427 test: fix ClassNotFoundException for Hive tests (#499)
6ea5a427 is described below

commit 6ea5a427eab1e93a8fc10e7cf76a6b14ba2f0c18
Author: KAZUYUKI TANIMURA <[email protected]>
AuthorDate: Fri May 31 15:11:35 2024 -0700

    test: fix ClassNotFoundException for Hive tests (#499)
    
    ## 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
---
 dev/diffs/3.4.2.diff | 2 +-
 dev/diffs/3.4.3.diff | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/dev/diffs/3.4.2.diff b/dev/diffs/3.4.2.diff
index 19bf6dd4..cd02970d 100644
--- a/dev/diffs/3.4.2.diff
+++ b/dev/diffs/3.4.2.diff
@@ -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")
diff --git a/dev/diffs/3.4.3.diff b/dev/diffs/3.4.3.diff
index ae46e916..c6d10c2e 100644
--- a/dev/diffs/3.4.3.diff
+++ b/dev/diffs/3.4.3.diff
@@ -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")


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to