This is an automated email from the ASF dual-hosted git repository.
wForget pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/gluten.git
The following commit(s) were added to refs/heads/main by this push:
new 37f518a095 [GLUTEN-12594][VL] Fix incorrect task attempt ID used for
Uniffle block IDs
37f518a095 is described below
commit 37f518a095caf94ce99e49d14dbfc3e1c7f55475
Author: Zhen Wang <[email protected]>
AuthorDate: Thu Jul 23 10:15:52 2026 +0800
[GLUTEN-12594][VL] Fix incorrect task attempt ID used for Uniffle block IDs
---
.../apache/spark/shuffle/gluten/uniffle/UniffleShuffleManager.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/backends-velox/src-uniffle/main/java/org/apache/spark/shuffle/gluten/uniffle/UniffleShuffleManager.java
b/backends-velox/src-uniffle/main/java/org/apache/spark/shuffle/gluten/uniffle/UniffleShuffleManager.java
index d63b3954dc..2d9db31849 100644
---
a/backends-velox/src-uniffle/main/java/org/apache/spark/shuffle/gluten/uniffle/UniffleShuffleManager.java
+++
b/backends-velox/src-uniffle/main/java/org/apache/spark/shuffle/gluten/uniffle/UniffleShuffleManager.java
@@ -54,6 +54,8 @@ public class UniffleShuffleManager extends RssShuffleManager
implements Supports
(ColumnarShuffleDependency<K, V, V>) rssHandle.getDependency();
setPusherAppId(rssHandle);
String taskId = context.taskAttemptId() + "_" + context.attemptNumber();
+ long rssTaskAttemptId =
+ getTaskAttemptIdForBlockId(context.partitionId(),
context.attemptNumber());
ShuffleWriteMetrics writeMetrics;
if (metrics != null) {
writeMetrics = new WriteMetrics(metrics);
@@ -72,7 +74,7 @@ public class UniffleShuffleManager extends RssShuffleManager
implements Supports
rssHandle.getAppId(),
rssHandle.getShuffleId(),
taskId,
- context.taskAttemptId(),
+ rssTaskAttemptId,
writeMetrics,
this,
conf,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
