[iotdb] branch master updated: [IOTDB-4652] Add retry logic of borrow client in MultiLeaderImpl (#7741)

[xingtanzjr]

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

xingtanzjr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new a2ccdeb91d [IOTDB-4652] Add retry logic of borrow client in 
MultiLeaderImpl (#7741)
a2ccdeb91d is described below

commit a2ccdeb91d524737d75eb7f01130a43c54b1bac0
Author: ZhangHongYin <46039728+sprico...@users.noreply.github.com>
AuthorDate: Mon Oct 31 14:40:33 2022 +0800

    [IOTDB-4652] Add retry logic of borrow client in MultiLeaderImpl (#7741)
---
 .../iotdb/consensus/multileader/logdispatcher/LogDispatcher.java       | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java
 
b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java
index 307fc141f7..9e428f4e09 100644
--- 
a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java
+++ 
b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java
@@ -59,7 +59,7 @@ import java.util.stream.Collectors;
 
 /** Manage all asynchronous replication threads and corresponding async 
clients */
 public class LogDispatcher {
-  private final Logger logger = LoggerFactory.getLogger(LogDispatcher.class);
+  private static final Logger logger = 
LoggerFactory.getLogger(LogDispatcher.class);
   private static final long DEFAULT_INITIAL_SYNC_INDEX = 0L;
   private final MultiLeaderServerImpl impl;
   private final List<LogDispatcherThread> threads;
@@ -432,6 +432,7 @@ public class LogDispatcher {
         client.syncLog(req, handler);
       } catch (IOException | TException e) {
         logger.error("Can not sync logs to peer {} because", peer, e);
+        handler.onError(e);
       }
     }