Using DB and table name when checking Delta table schema.

nousot · Jan 30, 2023 · f7e4675 · f7e4675 · mmuru · Jan 30, 2023
1 parent 7c036fb
commit f7e4675
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(t.identifier.table).schema
+            spark.table(f"${db}.${t.identifier.table}").schema
           } else {
             t.schema
           }