(paimon) branch master updated: [spark] use repartition instead of repartitionByRange to reduce the cost (#7061)

[lzljs3620320]

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 886489fa46 [spark] use repartition instead of repartitionByRange to 
reduce the cost (#7061)
886489fa46 is described below

commit 886489fa465cb2c317e52b48e4fc16ebd6c71b94
Author: WenjunMin <ait...@apache.org>
AuthorDate: Fri Jan 16 09:50:05 2026 +0800

    [spark] use repartition instead of repartitionByRange to reduce the cost 
(#7061)
---
 .../paimon/spark/commands/MergeIntoPaimonDataEvolutionTable.scala       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 ff6b8ccbb4..4f349e0cae 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
@@ -372,7 +372,7 @@ case class MergeIntoPaimonDataEvolutionTable(
       val withFirstRowId = addFirstRowId(sparkSession, mergeRows)
       assert(withFirstRowId.schema.fields.length == updateColumnsSorted.size + 
2)
       withFirstRowId
-        .repartitionByRange(col(FIRST_ROW_ID_NAME))
+        .repartition(col(FIRST_ROW_ID_NAME))
         .sortWithinPartitions(FIRST_ROW_ID_NAME, ROW_ID_NAME)
     }