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 <[email protected]> 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(),
