You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
### _Why are the changes needed?_
close#2672
### _How was this patch tested?_
- [X] 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#2673 from wForget/KYUUBI-2672.
Closes#2672a6c30d5 [wforget] [KYUUBI-2672] Check if the table exists
Authored-by: wforget <643348094@qq.com>
Signed-off-by: Cheng Pan <chengpan@apache.org>
Copy file name to clipboardExpand all lines: extensions/spark/kyuubi-spark-connector-tpcds/src/main/scala/org/apache/kyuubi/spark/connector/tpcds/TPCDSCatalog.scala
+1-1Lines changed: 1 addition & 1 deletion
Original file line number
Diff line number
Diff line change
@@ -52,7 +52,7 @@ class TPCDSCatalog extends TableCatalog with SupportsNamespaces {
52
52
}
53
53
54
54
overridedefloadTable(ident: Identifier):SparkTable= (ident.namespace, ident.name) match {
55
-
case (Array(db), table) if databases contains db =>
55
+
case (Array(db), table) if(databases contains db) && tables.contains(table.toLowerCase)=>
Copy file name to clipboardExpand all lines: extensions/spark/kyuubi-spark-connector-tpcds/src/test/scala/org/apache/kyuubi/spark/connector/tpcds/TPCDSCatalogSuite.scala
0 commit comments