From 20337dc968e1c9c751eb68d10303c3631c5fe49b Mon Sep 17 00:00:00 2001 From: Alex Wiss-Wolferding Date: Sat, 4 Feb 2023 13:39:33 -0600 Subject: [PATCH] Revert "Using DB and table name when checking Delta table schema." This reverts commit f7e4675a77a0d220e4b73dd5e54e4dba751c781e. --- .../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 1aa322d3154..5977cd415b0 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(f"${db}.${t.identifier.table}").schema + spark.table(t.identifier.table).schema } else { t.schema }