[iotdb] branch ml_0729_test updated: add log when timeout

[xingtanzjr]

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

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


The following commit(s) were added to refs/heads/ml_0729_test by this push:
     new e0ba6a638b add log when timeout
e0ba6a638b is described below

commit e0ba6a638b2a8691badb5184c7dcd8e1f1ce4de6
Author: Jinrui.Zhang <xingtan...@gmail.com>
AuthorDate: Fri Jul 29 19:08:16 2022 +0800

    add log when timeout
---
 .../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 7117e04509..2db1a8b204 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
@@ -65,7 +65,7 @@ public class DataRegionStateMachine extends BaseStateMachine {
   private DataRegion region;
 
   private static final int MAX_REQUEST_CACHE_SIZE = 5;
-  private static final long CACHE_WINDOW_TIME_IN_MS = 1000;
+  private static final long CACHE_WINDOW_TIME_IN_MS = 10_000;
   private final PriorityQueue<InsertNodeWrapper> requestCache;
   private final ReentrantLock lock = new ReentrantLock();
   private final Condition cacheCondition = lock.newCondition();
@@ -128,6 +128,7 @@ public class DataRegionStateMachine extends 
BaseStateMachine {
           boolean timeoutTriggered =
               !cacheCondition.await(CACHE_WINDOW_TIME_IN_MS, 
TimeUnit.MILLISECONDS);
           if (timeoutTriggered) {
+            logger.warn("wait next write request timeout. {}", 
requestCache.peek().syncIndex);
             break;
           }
         } catch (InterruptedException e) {