diff --git a/dbt/adapters/spark/impl.py b/dbt/adapters/spark/impl.py index bddb7e7dd..1dc4b09c3 100644 --- a/dbt/adapters/spark/impl.py +++ b/dbt/adapters/spark/impl.py @@ -225,8 +225,8 @@ def set_relation_information(self, relation: BaseRelation): is_hudi: bool = "Provider: hudi" in information is_iceberg: bool = "Provider: iceberg" in information relation: BaseRelation = self.Relation.create( - schema=_schema, - identifier=name, + schema=relation.schema, + identifier=relation.identifier, type=rel_type, information=information, is_delta=is_delta,