Fix iceberg catalog name issue

Signed-off-by: Chen Dai <[email protected]>
dai-chen · May 3, 2024 · 9a4eba8 · 9a4eba8
1 parent fcae77a
commit 9a4eba8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...tion/src/main/scala/org/opensearch/flint/spark/source/iceberg/IcebergSourceRelation.scala b/...tion/src/main/scala/org/opensearch/flint/spark/source/iceberg/IcebergSourceRelation.scala
@@ -22,7 +22,7 @@ case class IcebergSourceRelation(override val plan: DataSourceV2Relation)
     extends FlintSparkSourceRelation {
 
   override def tableName: String =
-    plan.table.name()
+    plan.identifier.map(_.toString()).get
 
   override def output: Seq[AttributeReference] = plan.output
 }