[iotdb] branch ml_0808_test_exp1_parallel updated: add log for queue size

[xingtanzjr]

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

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


The following commit(s) were added to refs/heads/ml_0808_test_exp1_parallel by 
this push:
     new dd4dc794ed add log for queue size
dd4dc794ed is described below

commit dd4dc794ed00fc17dd6e2d9483436433769f5f73
Author: Jinrui.Zhang <xingtan...@gmail.com>
AuthorDate: Tue Aug 9 14:30:55 2022 +0800

    add log for queue size
---
 .../apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java
 
b/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java
index 331bb7a634..d60f3eacf4 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java
@@ -125,8 +125,9 @@ public class DataRegionStateMachine extends 
BaseStateMachine {
   private TSStatus cacheAndInsertLatestNode(InsertNodeWrapper 
insertNodeWrapper) {
     long cacheRequestStartTime = System.nanoTime();
     logger.info(
-        "region = {}, syncIndex = {}, nextSyncIndex = {}",
+        "region = {}, queue size = {}, syncIndex = {}, nextSyncIndex = {}",
         region.getDataRegionId(),
+        requestCache.size(),
         insertNodeWrapper.startSyncIndex,
         nextSyncIndex);
     queueLock.lock();