diff --git a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/execution/PaimonStrategy.scala b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/execution/PaimonStrategy.scala index fb7bc6b22cd3..f2bfc7846b90 100644 --- a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/execution/PaimonStrategy.scala +++ b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/execution/PaimonStrategy.scala @@ -18,7 +18,7 @@ package org.apache.paimon.spark.execution -import org.apache.paimon.spark.{SparkCatalog, SparkUtils} +import org.apache.paimon.spark.{SparkCatalog, SparkGenericCatalog, SparkUtils} import org.apache.paimon.spark.catalog.SupportView import org.apache.paimon.spark.catalyst.analysis.ResolvedPaimonView import org.apache.paimon.spark.catalyst.plans.logical.{CreateOrReplaceTagCommand, CreatePaimonView, DeleteTagCommand, DropPaimonView, PaimonCallCommand, RenameTagCommand, ResolvedIdentifier, ShowPaimonViews, ShowTagsCommand} @@ -125,6 +125,8 @@ case class PaimonStrategy(spark: SparkSession) catalogAndIdentifier.catalog match { case paimonCatalog: SparkCatalog => Some((paimonCatalog, catalogAndIdentifier.identifier())) + case paimonCatalog: SparkGenericCatalog => + Some((paimonCatalog, catalogAndIdentifier.identifier())) case _ => None }