fix

apache · Jan 25, 2024 · 405b124 · 405b124
1 parent 615b747
commit 405b124
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/...ark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/util/SparkCatalogUtils.scala b/...ark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/util/SparkCatalogUtils.scala
@@ -163,16 +163,17 @@ object SparkCatalogUtils extends Logging {
     val namespaces = listNamespacesWithPattern(catalog, schemaPattern)
     catalog match {
       case builtin if builtin.name() == SESSION_CATALOG =>
-        val catalog = spark.sessionState.catalog
-        val databases = catalog.listDatabases(schemaPattern)
+        val sessionCatalog = spark.sessionState.catalog
+        val databases = sessionCatalog.listDatabases(schemaPattern)
 
         def isMatchedTableType(tableTypes: Set[String], tableType: String): Boolean = {
           val typ = if (tableType.equalsIgnoreCase(VIEW)) VIEW else TABLE
           tableTypes.exists(typ.equalsIgnoreCase)
         }
 
         databases.flatMap { db =>
-          val identifiers = catalog.listTables(db, tablePattern, includeLocalTempViews = false)
+          val identifiers =
+            sessionCatalog.listTables(db, tablePattern, includeLocalTempViews = false)
           if (ignoreTableProperties) {
             identifiers.map {
               case TableIdentifier(
@@ -192,7 +193,7 @@ object SparkCatalogUtils extends Logging {
                   null)
             }
           } else {
-            catalog.getTablesByName(identifiers)
+            sessionCatalog.getTablesByName(identifiers)
               .filter(t => isMatchedTableType(tableTypes, t.tableType.name)).map { t =>
                 val typ = if (t.tableType.name == VIEW) VIEW else TABLE
                 Row(