Skip to content

Commit 2646d4f

Browse files
committed
style
1 parent 79a9f33 commit 2646d4f

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/session/SparkSessionImpl.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -57,8 +57,9 @@ class SparkSessionImpl(
5757
try {
5858
SparkCatalogShim().setCurrentDatabase(spark, database)
5959
} catch {
60-
case e if database == "default" && e.getMessage != null &&
61-
e.getMessage.contains("not found") =>
60+
case e
61+
if database == "default" && e.getMessage != null &&
62+
e.getMessage.contains("not found") =>
6263
// use:database is from hive so the catalog is always session catalog which must have
6364
// default namespace `default`. But as spark support v2 catalog, catalog may not have
6465
// default namespace. Here we do nothing for compatible both session and v2 catalog.

0 commit comments

Comments
 (0)