Revert "Using DB and table name when checking Delta table schema."

This reverts commit f7e4675.
apache · Feb 4, 2023 · 20337dc · 20337dc
1 parent f7e4675
commit 20337dc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...park-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/shim/CatalogShim_v2_4.scala b/...park-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/shim/CatalogShim_v2_4.scala
@@ -141,7 +141,7 @@ class CatalogShim_v2_4 extends SparkCatalogShim {
       catalog.getTablesByName(identifiers).flatMap { t =>
         val tableSchema =
           if (t.provider.getOrElse("").equalsIgnoreCase("delta")) {
-            spark.table(f"${db}.${t.identifier.table}").schema
+            spark.table(t.identifier.table).schema
           } else {
             t.schema
           }