[incubator-celeborn] branch 6f043f8ae9f updated: add logs

[zh...@apache.org]

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

zhouky pushed a commit to branch 6f043f8ae9f
in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git


The following commit(s) were added to refs/heads/6f043f8ae9f by this push:
     new cf8e238a add logs
cf8e238a is described below

commit cf8e238a913211d38fd293e9cd9f9deef343dfc8
Author: zky.zhoukeyong <zk...@alibaba-inc.com>
AuthorDate: Wed Nov 23 14:37:22 2022 +0800

    add logs
---
 .../main/java/org/apache/celeborn/client/read/WorkerPartitionReader.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/client/src/main/java/org/apache/celeborn/client/read/WorkerPartitionReader.java b/client/src/main/java/org/apache/celeborn/client/read/WorkerPartitionReader.java
index bb17f31f..a3ef3615 100644
--- a/client/src/main/java/org/apache/celeborn/client/read/WorkerPartitionReader.java
+++ b/client/src/main/java/org/apache/celeborn/client/read/WorkerPartitionReader.java
@@ -88,6 +88,7 @@ public class WorkerPartitionReader implements PartitionReader {
               exception.set(new IOException(errorMsg, e));
             } else {
               try {
+                logger.info("onFailure, {}, try to change location", location);
                 synchronized (WorkerPartitionReader.this) {
                   if (!failedLocations.contains(location)) {
                     failedLocations.add(location);