This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 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 da94af7a77 [spark] Avoid unnecessary repeated resolve MergeIntoTable
(#6275)
da94af7a77 is described below
commit da94af7a7762d2f18d2652175cc34304857b579b
Author: Zouxxyy <[email protected]>
AuthorDate: Wed Sep 17 18:31:39 2025 +0800
[spark] Avoid unnecessary repeated resolve MergeIntoTable (#6275)
---
.../org/apache/paimon/spark/catalyst/analysis/PaimonAnalysis.scala | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/PaimonAnalysis.scala
b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/PaimonAnalysis.scala
index f44d9274e4..1ee0687faa 100644
---
a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/PaimonAnalysis.scala
+++
b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/PaimonAnalysis.scala
@@ -54,7 +54,8 @@ class PaimonAnalysis(session: SparkSession) extends
Rule[LogicalPlan] {
case o @ PaimonDynamicPartitionOverwrite(r, d) if o.resolved =>
PaimonDynamicPartitionOverwriteCommand(r, d, o.query, o.writeOptions,
o.isByName)
- case merge: MergeIntoTable if isPaimonTable(merge.targetTable) &&
merge.childrenResolved =>
+ case merge: MergeIntoTable
+ if !merge.resolved && isPaimonTable(merge.targetTable) &&
merge.childrenResolved =>
PaimonMergeIntoResolver(merge, session)
case s @ ShowColumns(PaimonRelation(table), _, _) if s.resolved =>
