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/07/29 11:08:28 UTC
[iotdb] branch ml_0729_test updated: add log when timeout
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 <xi...@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) {