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/08/11 02:42:12 UTC
[iotdb] 02/02: add log before test
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch ml_0810_test
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 5a32a3aaf74d5a987709c59396e26296dc8ec7eb
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Thu Aug 11 10:41:58 2022 +0800
add log before test
---
.../consensus/multileader/logdispatcher/LogDispatcher.java | 14 ++++++++++++--
1 file changed, 12 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 9a4637302f..7166b39311 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
@@ -207,6 +207,12 @@ public class LogDispatcher {
// we may block here if the synchronization pipeline is full
syncStatus.addNextBatch(batch);
// sends batch asynchronously and migrates the retry logic into the callback handler
+ logger.info(
+ "[SendBatch] -> DataRegion[{}]->[{}], startIndex: {}, endIndex: {}",
+ peer.getGroupId().getId(),
+ peer.getEndpoint().ip,
+ batch.getStartIndex(),
+ batch.getEndIndex());
sendBatchAsync(batch, new DispatchLogHandler(this, batch));
}
} catch (InterruptedException e) {
@@ -229,7 +235,11 @@ public class LogDispatcher {
List<TLogBatch> logBatches = new ArrayList<>();
long startIndex = syncStatus.getNextSendingIndex();
long maxIndexWhenBufferedRequestEmpty = startIndex;
- logger.debug("[GetBatch] startIndex: {}", startIndex);
+ logger.info(
+ "[GetBatch] -> DataRegion[{}]->[{}] prepare, startIndex: {}",
+ peer.getGroupId().getId(),
+ peer.getEndpoint().ip,
+ startIndex);
long endIndex;
if (bufferedRequest.size() <= config.getReplication().getMaxRequestPerBatch()) {
// Use drainTo instead of poll to reduce lock overhead
@@ -334,7 +344,7 @@ public class LogDispatcher {
private long constructBatchFromWAL(
long currentIndex, long maxIndex, List<TLogBatch> logBatches) {
- logger.info(
+ logger.debug(
String.format(
"DataRegion[%s]->%s: currentIndex: %d, maxIndex: %d, iteratorIndex: %d",
peer.getGroupId().getId(),