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);