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