diff --git a/extensions/spark/kyuubi-spark-authz/src/main/scala/org/apache/kyuubi/plugin/spark/authz/serde/tableExtractors.scala b/extensions/spark/kyuubi-spark-authz/src/main/scala/org/apache/kyuubi/plugin/spark/authz/serde/tableExtractors.scala index 82448f9cd..678175675 100644 --- a/extensions/spark/kyuubi-spark-authz/src/main/scala/org/apache/kyuubi/plugin/spark/authz/serde/tableExtractors.scala +++ b/extensions/spark/kyuubi-spark-authz/src/main/scala/org/apache/kyuubi/plugin/spark/authz/serde/tableExtractors.scala @@ -189,7 +189,7 @@ class DataSourceV2RelationTableExtractor extends TableExtractor { val plan = v1.asInstanceOf[LogicalPlan] plan.find(_.getClass.getSimpleName == "DataSourceV2Relation").get match { case v2Relation: DataSourceV2Relation - if v2Relation.identifier == None || + if v2Relation.identifier.isEmpty || !isPathIdentifier(v2Relation.identifier.get.name(), spark) => val maybeCatalog = v2Relation.catalog.flatMap(catalogPlugin => lookupExtractor[CatalogPluginCatalogExtractor].apply(catalogPlugin)) diff --git a/extensions/spark/kyuubi-spark-authz/src/main/scala/org/apache/kyuubi/plugin/spark/authz/serde/uriExtractors.scala b/extensions/spark/kyuubi-spark-authz/src/main/scala/org/apache/kyuubi/plugin/spark/authz/serde/uriExtractors.scala index eff842746..07b2408ba 100644 --- a/extensions/spark/kyuubi-spark-authz/src/main/scala/org/apache/kyuubi/plugin/spark/authz/serde/uriExtractors.scala +++ b/extensions/spark/kyuubi-spark-authz/src/main/scala/org/apache/kyuubi/plugin/spark/authz/serde/uriExtractors.scala @@ -122,7 +122,7 @@ class DataSourceV2RelationURIExtractor extends URIExtractor { val plan = v1.asInstanceOf[LogicalPlan] plan.find(_.getClass.getSimpleName == "DataSourceV2Relation").get match { case v2Relation: DataSourceV2Relation - if v2Relation.identifier != None && + if v2Relation.identifier.isDefined && isPathIdentifier(v2Relation.identifier.get.name, spark) => Seq(v2Relation.identifier.get.name).map(Uri) case _ => Nil