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 5986591c9 [#2733] fix(spark): Calculate total value for 
`ShuffleReadTimesSummary` (#2734)
5986591c9 is described below

commit 5986591c96d9e7f628e4cfbf6c7e342841af5706
Author: Zhen Wang <[email protected]>
AuthorDate: Sat Feb 28 09:45:18 2026 +0800

    [#2733] fix(spark): Calculate total value for `ShuffleReadTimesSummary` 
(#2734)
    
    ### What changes were proposed in this pull request?
    
    Calculate total value for ShuffleReadTimesSummary.
    
    ### Why are the changes needed?
    
    Fix the total shuffle read time to zero in uniffle UI.
    
    Closes #2733
    
    ### Does this PR introduce _any_ user-facing change?
    
    No.
    
    ### How was this patch tested?
    
    After:
    <img width="1865" height="131" alt="image" 
src="https://github.com/user-attachments/assets/1ca5ee6c-24cc-45b8-b580-8d760273574a";
 />
---
 .../extension/src/main/scala/org/apache/spark/UniffleStatusStore.scala   | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/client-spark/extension/src/main/scala/org/apache/spark/UniffleStatusStore.scala
 
b/client-spark/extension/src/main/scala/org/apache/spark/UniffleStatusStore.scala
index 6fde10e70..43a633ec4 100644
--- 
a/client-spark/extension/src/main/scala/org/apache/spark/UniffleStatusStore.scala
+++ 
b/client-spark/extension/src/main/scala/org/apache/spark/UniffleStatusStore.scala
@@ -188,6 +188,7 @@ case class ShuffleReadTimesSummary(var fetch: Long = 0,
                                    var total: Long = 0) {
   def inc(times: ShuffleReadTimes): Unit = {
     if (times == null) return
+    this.total += times.getTotal
     this.fetch += times.getFetch
     this.crc += times.getCrc
     this.copy += times.getCopy

Reply via email to