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/04 08:33:55 UTC

[iotdb] branch ml_test_1_async updated: change info to debug

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

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


The following commit(s) were added to refs/heads/ml_test_1_async by this push:
     new 3e0e1debff change info to debug
3e0e1debff is described below

commit 3e0e1debff3c3250b6f03d76866ba708d7c17208
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Thu Aug 4 16:33:44 2022 +0800

    change info to debug
---
 .../iotdb/consensus/multileader/logdispatcher/LogDispatcher.java      | 4 ++--
 1 file changed, 2 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 da5ad41aaa..6eb7c2e7de 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
@@ -117,7 +117,7 @@ public class LogDispatcher {
           if (!thread
               .getPendingRequest()
               .offer(new IndexedConsensusRequest(serializedRequest, request.getSearchIndex()))) {
-            logger.info(
+            logger.debug(
                 "{}: Log queue to {} is full. skip current request: {}",
                 impl.getThisNode().getGroupId(),
                 thread.getPeer().getEndpoint().getIp(),
@@ -170,7 +170,7 @@ public class LogDispatcher {
 
     public void countQueueUsage(long searchIndex) {
       this.queueProcessCount++;
-      logger.info(
+      logger.debug(
           "{}: queue to {}: put request to queue. count: {}, searchIndex {}",
           impl.getThisNode().getGroupId(),
           getPeer().getEndpoint().getIp(),