fix

zhaohehuhu · Jan 29, 2024 · 058001c · 058001c
1 parent 405b124
commit 058001c
Showing 1 changed file with 12 additions and 16 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
@@ -175,22 +175,18 @@ object SparkCatalogUtils extends Logging {
           val identifiers =
             sessionCatalog.listTables(db, tablePattern, includeLocalTempViews = false)
           if (ignoreTableProperties) {
-            identifiers.map {
-              case TableIdentifier(
-                    table: String,
-                    database: Option[String],
-                    catalog: Option[String]) =>
-                Row(
-                  catalog.getOrElse(catalogName),
-                  database.getOrElse("default"),
-                  table,
-                  TABLE, // ignore tableTypes criteria and simply treat all table type as TABLE
-                  "",
-                  null,
-                  null,
-                  null,
-                  null,
-                  null)
+            identifiers.map { ti: TableIdentifier =>
+              Row(
+                catalogName,
+                ti.database.getOrElse("default"),
+                ti.table,
+                TABLE, // ignore tableTypes criteria and simply treat all table type as TABLE
+                "",
+                null,
+                null,
+                null,
+                null,
+                null)
             }
           } else {
             sessionCatalog.getTablesByName(identifiers)