(auron) branch master updated: [AURON #1707] Bump Celeborn 0.6.2 (#1741)

[csy]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 8ab5b5a4 [AURON #1707] Bump Celeborn 0.6.2 (#1741)
8ab5b5a4 is described below

commit 8ab5b5a49cca1017a45e8453ace39060a78b8078
Author: bkhan <xor...@outlook.com>
AuthorDate: Fri Dec 12 18:57:18 2025 +0800

    [AURON #1707] Bump Celeborn 0.6.2 (#1741)
    
    # Which issue does this PR close?
    
    Closes #1707
    
    # Rationale for this change
    
    # What changes are included in this PR?
    
    # Are there any user-facing changes?
    
    # How was this patch tested?
---
 pom.xml                                                                 | 2 +-
 .../sql/execution/auron/shuffle/celeborn/CelebornPartitionWriter.scala  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/pom.xml b/pom.xml
index 03e6279a..7a05fdf3 100644
--- a/pom.xml
+++ b/pom.xml
@@ -792,7 +792,7 @@
         <module>thirdparty/auron-celeborn-0.6</module>
       </modules>
       <properties>
-        <celebornVersion>0.6.1</celebornVersion>
+        <celebornVersion>0.6.2</celebornVersion>
       </properties>
     </profile>
 
diff --git 
a/thirdparty/auron-celeborn-0.6/src/main/scala/org/apache/spark/sql/execution/auron/shuffle/celeborn/CelebornPartitionWriter.scala
 
b/thirdparty/auron-celeborn-0.6/src/main/scala/org/apache/spark/sql/execution/auron/shuffle/celeborn/CelebornPartitionWriter.scala
index 0534feb0..558e459b 100644
--- 
a/thirdparty/auron-celeborn-0.6/src/main/scala/org/apache/spark/sql/execution/auron/shuffle/celeborn/CelebornPartitionWriter.scala
+++ 
b/thirdparty/auron-celeborn-0.6/src/main/scala/org/apache/spark/sql/execution/auron/shuffle/celeborn/CelebornPartitionWriter.scala
@@ -65,7 +65,7 @@ class CelebornPartitionWriter(
   override def close(success: Boolean): Unit = {
     val waitStartTime = System.nanoTime()
     if (success) {
-      shuffleClient.mapperEnd(shuffleId, mapId, encodedAttemptId, numMappers)
+      shuffleClient.mapperEnd(shuffleId, mapId, encodedAttemptId, numMappers, 
numPartitions)
     }
     shuffleClient.cleanup(shuffleId, mapId, encodedAttemptId)
     metrics.incWriteTime(System.nanoTime() - waitStartTime)