This is an automated email from the ASF dual-hosted git repository. rexxiong pushed a commit to branch branch-0.3 in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git
commit 870fdc848ac122b346e8ab227a98da3f084f8263 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]> (cherry picked from commit 9a104f9c716f960ccf8dea0991a649bbfcbb35e7) 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 133ac5cd2..141ae7b7a 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 @@ -315,13 +315,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",
