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
commit c5d366b094c7be48de3744855009f629929c12b2 Author: onebox-li <[email protected]> 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 | 5 +---- 1 file changed, 1 insertion(+), 4 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..b9a0cdd9f 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 @@ -36,7 +36,6 @@ import org.apache.celeborn.client.compress.Decompressor; import org.apache.celeborn.common.CelebornConf; import org.apache.celeborn.common.exception.CelebornIOException; import org.apache.celeborn.common.network.client.TransportClientFactory; -import org.apache.celeborn.common.network.util.TransportConf; import org.apache.celeborn.common.protocol.CompressionCodec; import org.apache.celeborn.common.protocol.PartitionLocation; import org.apache.celeborn.common.protocol.StorageInfo; @@ -210,9 +209,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;
