[iotdb] branch test_wal_sync updated: add more logs

[xingtanzjr]

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

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


The following commit(s) were added to refs/heads/test_wal_sync by this push:
     new 2acd487154 add more logs
2acd487154 is described below

commit 2acd487154f8c109905a56436ace3b0e08e0da3c
Author: Jinrui.Zhang <xingtan...@gmail.com>
AuthorDate: Tue Jun 28 16:32:29 2022 +0800

    add more logs
---
 .../iotdb/consensus/multileader/logdispatcher/LogDispatcher.java  | 8 ++++++--
 .../src/main/java/org/apache/iotdb/db/wal/buffer/WALBuffer.java   | 1 +
 2 files changed, 7 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 2db1c62d98..5af75547a3 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
@@ -295,8 +295,12 @@ public class LogDispatcher {
         long currentIndex, long maxIndex, List<TLogBatch> logBatches) {
       logger.info(
           String.format(
-              "DataRegion[%s]->%s: currentIndex: %d, maxIndex: %d",
-              peer.getGroupId().getId(), peer.getEndpoint().ip, currentIndex, 
maxIndex));
+              "DataRegion[%s]->%s: currentIndex: %d, maxIndex: %d, 
iteratorIndex: %d",
+              peer.getGroupId().getId(),
+              peer.getEndpoint().ip,
+              currentIndex,
+              maxIndex,
+              iteratorIndex));
       long startTime = System.nanoTime();
       int count = 0;
       try {
diff --git a/server/src/main/java/org/apache/iotdb/db/wal/buffer/WALBuffer.java 
b/server/src/main/java/org/apache/iotdb/db/wal/buffer/WALBuffer.java
index 6626ce7f91..c35808e869 100644
--- a/server/src/main/java/org/apache/iotdb/db/wal/buffer/WALBuffer.java
+++ b/server/src/main/java/org/apache/iotdb/db/wal/buffer/WALBuffer.java
@@ -223,6 +223,7 @@ public class WALBuffer extends AbstractWALBuffer {
         if (insertNode.getSearchIndex() != InsertNode.NO_CONSENSUS_INDEX) {
           currentSearchIndex = insertNode.getSearchIndex();
           currentFileStatus = WALFileStatus.CONTAINS_SEARCH_INDEX;
+          logger.info("WALEntry searchIndex: {}", currentSearchIndex);
         }
       }
       return true;