From f7e4675a77a0d220e4b73dd5e54e4dba751c781e Mon Sep 17 00:00:00 2001 From: Alex Wiss-Wolferding Date: Mon, 30 Jan 2023 12:49:32 -0600 Subject: [PATCH] Using DB and table name when checking Delta table schema. --- .../org/apache/kyuubi/engine/spark/shim/CatalogShim_v2_4.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/shim/CatalogShim_v2_4.scala b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/shim/CatalogShim_v2_4.scala index 5977cd415b0..1aa322d3154 100644 --- a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/shim/CatalogShim_v2_4.scala +++ b/externals/kyuubi-spark-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 }