You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/09/19 03:58:47 UTC

[iotdb] branch ml_optimize_reader_test updated: spotless log

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

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


The following commit(s) were added to refs/heads/ml_optimize_reader_test by this push:
     new efad541ccd spotless log
efad541ccd is described below

commit efad541ccd579ef0a0c28e9af104c03c0a11607f
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Mon Sep 19 11:58:31 2022 +0800

    spotless log
---
 .../iotdb/consensus/multileader/logdispatcher/LogDispatcher.java     | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

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 938ced77cf..2dcbdd7f57 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
@@ -327,10 +327,11 @@ public class LogDispatcher {
         TSyncLogReq req =
             new TSyncLogReq(peer.getGroupId().convertToTConsensusGroupId(), batch.getBatches());
         logger.info(
-            "Send Batch[startIndex:{}, endIndex:{}] to ConsensusGroup:{}",
+            "Send Batch[startIndex:{}, endIndex:{}] to {} - {}",
             batch.getStartIndex(),
             batch.getEndIndex(),
-            peer.getGroupId().convertToTConsensusGroupId());
+            peer.getEndpoint().getIp(),
+            peer.getGroupId().convertToTConsensusGroupId().getId());
         client.syncLog(req, handler);
       } catch (IOException | TException e) {
         logger.error("Can not sync logs to peer {} because", peer, e);