(celeborn) branch branch-0.4 updated: [CELEBORN-1381] Avoid construct TransportConf when creating CelebornInputStream

[nicholasjiang]

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

nicholasjiang pushed a commit to branch branch-0.4
in repository https://gitbox.apache.org/repos/asf/celeborn.git


The following commit(s) were added to refs/heads/branch-0.4 by this push:
     new f4ca2a230 [CELEBORN-1381] Avoid construct TransportConf when creating 
CelebornInputStream
f4ca2a230 is described below

commit f4ca2a2302227be3a26faeee495742b0feb9215f
Author: onebox-li <lyh...@163.com>
AuthorDate: Fri Apr 12 14:06:54 2024 +0800

    [CELEBORN-1381] Avoid construct TransportConf when creating 
CelebornInputStream
---
 .../java/org/apache/celeborn/client/read/CelebornInputStream.java     | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/client/src/main/java/org/apache/celeborn/client/read/CelebornInputStream.java 
b/client/src/main/java/org/apache/celeborn/client/read/CelebornInputStream.java
index a10239bf5..f3611b931 100644
--- 
a/client/src/main/java/org/apache/celeborn/client/read/CelebornInputStream.java
+++ 
b/client/src/main/java/org/apache/celeborn/client/read/CelebornInputStream.java
@@ -210,9 +210,7 @@ public abstract class CelebornInputStream extends 
InputStream {
       } else {
         fetchChunkMaxRetry = conf.clientFetchMaxRetriesForEachReplica();
       }
-      TransportConf transportConf =
-          Utils.fromCelebornConf(conf, TransportModuleConstants.DATA_MODULE, 
0);
-      retryWaitMs = transportConf.ioRetryWaitTimeMs();
+      this.retryWaitMs = 
conf.networkIoRetryWaitMs(TransportModuleConstants.DATA_MODULE);
       this.callback = metricsCallback;
       this.exceptionMaker = exceptionMaker;
       this.partitionId = partitionId;