(paimon) branch master updated: [spark] to DE insert into path,the target table should also be target splits (#9333)

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

JingsongLi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new a17cee8e9d [spark] to DE insert into path,the target table should also 
be target splits (#9333)
a17cee8e9d is described below

commit a17cee8e9d82eb1459e452da5a2a239b6dac3804
Author: weijie <tongweijie...@gmail.com>
AuthorDate: Fri Aug 21 14:15:31 2026 +0800

    [spark] to DE insert into path,the target table should also be target 
splits (#9333)
---
 .../paimon/spark/commands/MergeIntoPaimonDataEvolutionTable.scala       | 2 +-
 .../paimon/spark/commands/MergeIntoPaimonDataEvolutionTable.scala       | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/paimon-spark/paimon-spark-4.0/src/main/scala/org/apache/paimon/spark/commands/MergeIntoPaimonDataEvolutionTable.scala
 
b/paimon-spark/paimon-spark-4.0/src/main/scala/org/apache/paimon/spark/commands/MergeIntoPaimonDataEvolutionTable.scala
index 4585f75885..fd70124ab5 100644
--- 
a/paimon-spark/paimon-spark-4.0/src/main/scala/org/apache/paimon/spark/commands/MergeIntoPaimonDataEvolutionTable.scala
+++ 
b/paimon-spark/paimon-spark-4.0/src/main/scala/org/apache/paimon/spark/commands/MergeIntoPaimonDataEvolutionTable.scala
@@ -838,7 +838,7 @@ case class MergeIntoPaimonDataEvolutionTable(
       mergeFields.filter(field => targetTable.output.exists(attr => 
attr.equals(field)))
 
     val targetReadPlan =
-      touchedFileTargetRelation.copy(targetRelation.table, 
allReadFieldsOnTarget.toSeq)
+      touchedFileTargetRelation.copy(output = allReadFieldsOnTarget.toSeq)
     val sourceReadPlan = 
persistSourceDss.map(_.queryExecution.logical).getOrElse(sourceTable)
 
     val joinPlan =
diff --git 
a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/MergeIntoPaimonDataEvolutionTable.scala
 
b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/MergeIntoPaimonDataEvolutionTable.scala
index e739036303..42ffd2ad3c 100644
--- 
a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/MergeIntoPaimonDataEvolutionTable.scala
+++ 
b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/MergeIntoPaimonDataEvolutionTable.scala
@@ -837,7 +837,7 @@ case class MergeIntoPaimonDataEvolutionTable(
       mergeFields.filter(field => targetTable.output.exists(attr => 
attr.equals(field)))
 
     val targetReadPlan =
-      touchedFileTargetRelation.copy(targetRelation.table, 
allReadFieldsOnTarget.toSeq)
+      touchedFileTargetRelation.copy(output = allReadFieldsOnTarget.toSeq)
     val sourceReadPlan = 
persistSourceDss.map(_.queryExecution.logical).getOrElse(sourceTable)
 
     val joinPlan =