Misleading exception is thrown when a non-exsiting catalog is referenced

Description

if `xyz` catalog doesn't exist, the following exception is thrown

scala> spark.read.table("xyz.ks.kv").show() org.apache.spark.sql.AnalysisException: The namespace in session catalog must have exactly one name part: xx.ks.kv; at org.apache.spark.sql.connector.catalog.LookupCatalog$SessionCatalogAndIdentifier$.unapply(LookupCatalog.scala:65) at org.apache.spark.sql.catalyst.analysis.Analyzer$ResolveRelations$.org$apache$spark$sql$catalyst$analysis$Analyzer$ResolveRelations$$lookupRelation(Analyzer.scala:1009) at org.apache.spark.sql.catalyst.analysis.Analyzer$ResolveRelations$$anonfun$apply$9.applyOrElse(Analyzer.scala:977) at org.apache.spark.sql.catalyst.analysis.Analyzer$ResolveRelations$$anonfun$apply$9.applyOrElse(Analyzer.scala:962) at org.apache.spark.sql.catalyst.plans.logical.AnalysisHelper.$anonfun$resolveOperatorsUp$3(AnalysisHelper.scala:90) at org.apache.spark.sql.catalyst.trees.CurrentOrigin$.withOrigin(TreeNode.scala:72) at org.apache.spark.sql.catalyst.plans.logical.AnalysisHelper.$anonfun$resolveOperatorsUp$1(AnalysisHelper.scala:90) at org.apache.spark.sql.catalyst.plans.logical.AnalysisHelper$.allowInvokingTransformsInAnalyzer(AnalysisHelper.scala:194)

We should throw an exception that is more meaningful.

Pull Requests

None

Activity

Show:

Details

Assignee

Reporter

Fix versions

Affects versions

Priority

Created September 24, 2020 at 10:42 AM
Updated April 7, 2021 at 2:34 PM

Flag notifications