This is an automated email from the ASF dual-hosted git repository. rexxiong pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git
commit 6f328382b344646edbb261f4c098af9c05dda4ab Author: jiaoqingbo <[email protected]> AuthorDate: Thu Nov 23 19:58:13 2023 +0800 [CELEBORN-1138] Fix log error in createReaderWithRetry method As Title As Title NO PASS GA Closes #2111 from jiaoqingbo/1138. Authored-by: jiaoqingbo <[email protected]> Signed-off-by: Shuang <[email protected]> --- .../main/java/org/apache/celeborn/client/read/CelebornInputStream.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 29f635380..8484406c6 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 @@ -329,13 +329,13 @@ public abstract class CelebornInputStream extends InputStream { if (fetchChunkRetryCnt % 2 == 0) { Uninterruptibles.sleepUninterruptibly(retryWaitMs, TimeUnit.MILLISECONDS); } - location = location.getPeer(); logger.warn( "CreatePartitionReader failed {}/{} times for location {}, change to peer", fetchChunkRetryCnt, fetchChunkMaxRetry, location, e); + location = location.getPeer(); } else { logger.warn( "CreatePartitionReader failed {}/{} times for location {}, retry the same location",
