From 9a4eba8bcbefcbead91c99baf7aa6665c7299604 Mon Sep 17 00:00:00 2001 From: Chen Dai Date: Fri, 3 May 2024 15:57:23 -0700 Subject: [PATCH] Fix iceberg catalog name issue Signed-off-by: Chen Dai --- .../flint/spark/source/iceberg/IcebergSourceRelation.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flint-spark-integration/src/main/scala/org/opensearch/flint/spark/source/iceberg/IcebergSourceRelation.scala b/flint-spark-integration/src/main/scala/org/opensearch/flint/spark/source/iceberg/IcebergSourceRelation.scala index ff2b8e783..f0246509f 100644 --- a/flint-spark-integration/src/main/scala/org/opensearch/flint/spark/source/iceberg/IcebergSourceRelation.scala +++ b/flint-spark-integration/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 }