[incubator-uniffle] branch master updated: [#1062] fix(tez): Fix to use TezIdHelper to getTaskAttemptId instead of default IdHelper. (#1078)

[roryqi]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 5016970e [#1062] fix(tez): Fix to use TezIdHelper to getTaskAttemptId 
instead of default IdHelper. (#1078)
5016970e is described below

commit 5016970edd5b8ab76f59e4e04e27d8b979193db5
Author: Qing <1169158...@qq.com>
AuthorDate: Wed Aug 23 14:20:05 2023 +0800

    [#1062] fix(tez): Fix to use TezIdHelper to getTaskAttemptId instead of 
default IdHelper. (#1078)
    
    ### What changes were proposed in this pull request?
    
    Fix to use TezIdHelper to getTaskAttemptId instead of default IdHelper.
    
    ### Why are the changes needed?
    
    Fix to use TezIdHelper to getTaskAttemptId instead of default IdHelper.
    
    Fix: [#1062](https://github.com/apache/incubator-uniffle/issues/1062)
    
    ### Does this PR introduce _any_ user-facing change?
    
    
    No.
    
    ### How was this patch tested?
    CI passed.
---
 .../tez/runtime/library/common/shuffle/impl/RssTezFetcherTask.java      | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/RssTezFetcherTask.java
 
b/client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/RssTezFetcherTask.java
index 39b60d37..65ee99b4 100644
--- 
a/client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/RssTezFetcherTask.java
+++ 
b/client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/RssTezFetcherTask.java
@@ -29,6 +29,7 @@ import 
org.apache.hadoop.yarn.api.records.ApplicationAttemptId;
 import org.apache.tez.common.CallableWithNdc;
 import org.apache.tez.common.RssTezConfig;
 import org.apache.tez.common.RssTezUtils;
+import org.apache.tez.common.TezIdHelper;
 import org.apache.tez.runtime.api.InputContext;
 import org.apache.tez.runtime.library.common.InputAttemptIdentifier;
 import org.apache.tez.runtime.library.common.shuffle.FetchResult;
@@ -190,6 +191,7 @@ public class RssTezFetcherTask extends 
CallableWithNdc<FetchResult> {
               taskIdBitmap,
               new ArrayList<>(serverInfoSet),
               hadoopConf,
+              new TezIdHelper(),
               expectedTaskIdsBitmapFilterEnable,
               RssTezConfig.toRssConf(this.conf));
       ShuffleReadClient shuffleReadClient =