[iotdb] branch ml_0729_test_exp1_no_write updated: add log if the request cannot be put into queue

[xingtanzjr]

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

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


The following commit(s) were added to refs/heads/ml_0729_test_exp1_no_write by 
this push:
     new 6bd7b20476 add log if the request cannot be put into queue
6bd7b20476 is described below

commit 6bd7b204767dea1512801beb468e3ae6d610956f
Author: Jinrui.Zhang <xingtan...@gmail.com>
AuthorDate: Mon Aug 8 11:05:23 2022 +0800

    add log if the request cannot be put into queue
---
 .../iotdb/consensus/multileader/logdispatcher/LogDispatcher.java   | 7 ++++---
 1 file changed, 4 insertions(+), 3 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 eeecfcfaa6..aa4091f708 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
@@ -138,10 +138,11 @@ public class LogDispatcher {
               .offer(new IndexedConsensusRequest(serializedRequests, 
request.getSearchIndex()))) {
             thread.countQueue(request.getSearchIndex());
           } else {
-            logger.debug(
-                "{}: Log queue of {} is full, ignore the log to this node",
+            logger.info(
+                "{}: Log queue of {} is full, ignore the log to this node, 
searchIndex: {}",
                 impl.getThisNode().getGroupId(),
-                thread.getPeer());
+                thread.getPeer(),
+                request.getSearchIndex());
           }
         });
   }