Skip to content

Commit da94af7

Browse files
authored
[spark] Avoid unnecessary repeated resolve MergeIntoTable (#6275)
1 parent 37ebf45 commit da94af7

File tree

1 file changed

+2
-1
lines changed
  • paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis

1 file changed

+2
-1
lines changed

paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/PaimonAnalysis.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,8 @@ class PaimonAnalysis(session: SparkSession) extends Rule[LogicalPlan] {
5454
case o @ PaimonDynamicPartitionOverwrite(r, d) if o.resolved =>
5555
PaimonDynamicPartitionOverwriteCommand(r, d, o.query, o.writeOptions, o.isByName)
5656

57-
case merge: MergeIntoTable if isPaimonTable(merge.targetTable) && merge.childrenResolved =>
57+
case merge: MergeIntoTable
58+
if !merge.resolved && isPaimonTable(merge.targetTable) && merge.childrenResolved =>
5859
PaimonMergeIntoResolver(merge, session)
5960

6061
case s @ ShowColumns(PaimonRelation(table), _, _) if s.resolved =>

0 commit comments

Comments
 (0)