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

chengpan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-kyuubi.git


The following commit(s) were added to refs/heads/master by this push:
     new 18e9d09e6 [KYUUBI #2700] Handle SPARK-37929 breaking change in 
TPCDSCatalog
18e9d09e6 is described below

commit 18e9d09e6637dcdfc4663a27f575366ac1b4a0af
Author: Cheng Pan <[email protected]>
AuthorDate: Wed May 18 22:18:37 2022 +0800

    [KYUUBI #2700] Handle SPARK-37929 breaking change in TPCDSCatalog
    
    ### _Why are the changes needed?_
    
    Handle SPARK-37929 breaking change in TPCDSCatalog
    
    ### _How was this patch tested?_
    - [ ] Add some test cases that check the changes thoroughly including 
negative and positive cases if possible
    
    - [ ] Add screenshots for manual tests if appropriate
    
    - [ ] [Run 
test](https://kyuubi.apache.org/docs/latest/develop_tools/testing.html#running-tests)
 locally before make a pull request
    
    Closes #2700 from pan3793/tpcds.
    
    Closes #2700
    
    e4c5c236 [Cheng Pan] Handle SPARK-37929 breaking change in TPCDSCatalog
    
    Authored-by: Cheng Pan <[email protected]>
    Signed-off-by: Cheng Pan <[email protected]>
---
 .../org/apache/kyuubi/spark/connector/tpcds/TPCDSCatalog.scala     | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/extensions/spark/kyuubi-spark-connector-tpcds/src/main/scala/org/apache/kyuubi/spark/connector/tpcds/TPCDSCatalog.scala
 
b/extensions/spark/kyuubi-spark-connector-tpcds/src/main/scala/org/apache/kyuubi/spark/connector/tpcds/TPCDSCatalog.scala
index 11fa17140..d7a5dddcb 100644
--- 
a/extensions/spark/kyuubi-spark-connector-tpcds/src/main/scala/org/apache/kyuubi/spark/connector/tpcds/TPCDSCatalog.scala
+++ 
b/extensions/spark/kyuubi-spark-connector-tpcds/src/main/scala/org/apache/kyuubi/spark/connector/tpcds/TPCDSCatalog.scala
@@ -103,6 +103,11 @@ class TPCDSCatalog extends TableCatalog with 
SupportsNamespaces {
   override def alterNamespace(namespace: Array[String], changes: 
NamespaceChange*): Unit =
     throw new UnsupportedOperationException
 
-  override def dropNamespace(namespace: Array[String]): Boolean =
+  // Removed in SPARK-37929
+  def dropNamespace(namespace: Array[String]): Boolean =
+    throw new UnsupportedOperationException
+
+  // Introduced in SPARK-37929
+  def dropNamespace(namespace: Array[String], cascade: Boolean): Boolean =
     throw new UnsupportedOperationException
 }

Reply via email to