You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by lz...@apache.org on 2026/08/21 06:15:37 UTC
(paimon) branch master updated: [spark] to DE insert into path,the target table should also be target splits (#9333)
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 <to...@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 =