(uniffle) branch master updated: [#2483] fix(spark): Avoid `NoSuchElementException` error in data pusher (#2484)

[zuston]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new abb6bd52e [#2483] fix(spark): Avoid `NoSuchElementException` error in 
data pusher (#2484)
abb6bd52e is described below

commit abb6bd52ea1421310ac003235e4b5af8d13fb8f5
Author: Zhen Wang <643348...@qq.com>
AuthorDate: Fri May 16 17:42:15 2025 +0800

    [#2483] fix(spark): Avoid `NoSuchElementException` error in data pusher 
(#2484)
    
    ### What changes were proposed in this pull request?
    
    closes #2483
    
    ### Why are the changes needed?
    
    Avoid NoSuchElementException error
    
    ### Does this PR introduce _any_ user-facing change?
    
    No.
    
    ### How was this patch tested?
    
    minor fix
---
 .../src/main/java/org/apache/spark/shuffle/writer/DataPusher.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/client-spark/common/src/main/java/org/apache/spark/shuffle/writer/DataPusher.java
 
b/client-spark/common/src/main/java/org/apache/spark/shuffle/writer/DataPusher.java
index 5b3455179..2da75144e 100644
--- 
a/client-spark/common/src/main/java/org/apache/spark/shuffle/writer/DataPusher.java
+++ 
b/client-spark/common/src/main/java/org/apache/spark/shuffle/writer/DataPusher.java
@@ -124,7 +124,7 @@ public class DataPusher implements Closeable {
                   .filter(x -> succeedBlockIds.contains(x.getBlockId()))
                   .map(x -> x.getFreeMemory())
                   .reduce((a, b) -> a + b)
-                  .get();
+                  .orElse(0L);
             },
             executorService)
         .exceptionally(