[iotdb] branch test_wal_sync updated: change debug to info in logdispatcher

[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 9480c38981 change debug to info in logdispatcher
9480c38981 is described below

commit 9480c389811bd379ca21656af3e5ceca941982ec
Author: Jinrui.Zhang <xingtan...@gmail.com>
AuthorDate: Tue Jun 28 10:21:17 2022 +0800

    change debug to info in logdispatcher
---
 .../iotdb/consensus/multileader/logdispatcher/LogDispatcher.java  | 8 ++++----
 1 file changed, 4 insertions(+), 4 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 fdacd88442..cf3c1ae7fc 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
@@ -223,7 +223,7 @@ public class LogDispatcher {
         // only execute this after a restart
         endIndex = constructBatchFromWAL(startIndex, maxIndex, logBatches);
         batch = new PendingBatch(startIndex, endIndex, logBatches);
-        logger.debug("{} : accumulated a {} from wal", 
impl.getThisNode().getGroupId(), batch);
+        logger.info("{} : accumulated a {} from wal", 
impl.getThisNode().getGroupId(), batch);
       } else {
         Iterator<IndexedConsensusRequest> iterator = 
bufferedRequest.iterator();
         IndexedConsensusRequest prev = iterator.next();
@@ -232,7 +232,7 @@ public class LogDispatcher {
         endIndex = constructBatchFromWAL(startIndex, prev.getSearchIndex(), 
logBatches);
         if (logBatches.size() == 
config.getReplication().getMaxRequestPerBatch()) {
           batch = new PendingBatch(startIndex, endIndex, logBatches);
-          logger.debug("{} : accumulated a {} from wal", 
impl.getThisNode().getGroupId(), batch);
+          logger.info("{} : accumulated a {} from wal", 
impl.getThisNode().getGroupId(), batch);
           return batch;
         }
         constructBatchIndexedFromConsensusRequest(prev, logBatches);
@@ -248,7 +248,7 @@ public class LogDispatcher {
                 constructBatchFromWAL(prev.getSearchIndex(), 
current.getSearchIndex(), logBatches);
             if (logBatches.size() == 
config.getReplication().getMaxRequestPerBatch()) {
               batch = new PendingBatch(startIndex, endIndex, logBatches);
-              logger.debug(
+              logger.info(
                   "{} : accumulated a {} from queue and wal",
                   impl.getThisNode().getGroupId(),
                   batch);
@@ -264,7 +264,7 @@ public class LogDispatcher {
           iterator.remove();
         }
         batch = new PendingBatch(startIndex, endIndex, logBatches);
-        logger.debug(
+        logger.info(
             "{} : accumulated a {} from queue and wal", 
impl.getThisNode().getGroupId(), batch);
       }
       return batch;