From 50ccd323b2bfd7a8a25540f8ac5318c188e40f74 Mon Sep 17 00:00:00 2001 From: allisonwang-db Date: Thu, 14 Dec 2023 15:17:57 +0800 Subject: [PATCH] update --- .../execution/datasources/v2/DataSourceV2Relation.scala | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2Relation.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2Relation.scala index 8dae9904bc82..9c7d776edc65 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2Relation.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2Relation.scala @@ -66,13 +66,7 @@ case class DataSourceV2Relation( import org.apache.spark.sql.connector.catalog.CatalogV2Implicits._ (catalog, identifier) match { case (Some(cat), Some(ident)) => s"${quoteIfNeeded(cat.name())}.${ident.quoted}" - case (None, None) => table.name() - case _ => - throw SparkException.internalError( - "Invalid catalog and identifier pair. Both 'catalog' and 'identifier' must be " + - s"specified or leave as None. Current input - " + - s"catalog: '${catalog.map(_.name()).getOrElse(None)}', " + - s"identifier: ${identifier.map(_.quoted).getOrElse(None)}.") + case _ => table.name() } }