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/02 04:11:54 UTC
[iotdb] branch ml_0729_test_exp1 updated: change concurrent param to 5
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch ml_0729_test_exp1
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/ml_0729_test_exp1 by this push:
new 1a5cf785d2 change concurrent param to 5
1a5cf785d2 is described below
commit 1a5cf785d213ef1c7d14f57b7f6823176e267a91
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Tue Aug 2 12:11:38 2022 +0800
change concurrent param to 5
---
.../main/java/org/apache/iotdb/consensus/config/MultiLeaderConfig.java | 2 +-
.../apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/consensus/src/main/java/org/apache/iotdb/consensus/config/MultiLeaderConfig.java b/consensus/src/main/java/org/apache/iotdb/consensus/config/MultiLeaderConfig.java
index e4f66f557b..9d4665e4d4 100644
--- a/consensus/src/main/java/org/apache/iotdb/consensus/config/MultiLeaderConfig.java
+++ b/consensus/src/main/java/org/apache/iotdb/consensus/config/MultiLeaderConfig.java
@@ -249,7 +249,7 @@ public class MultiLeaderConfig {
public static class Builder {
private int maxPendingRequestNumPerNode = 200;
private int maxRequestPerBatch = 40;
- private int maxPendingBatch = 1;
+ private int maxPendingBatch = 5;
private int maxWaitingTimeForAccumulatingBatchInMs = 500;
private long basicRetryWaitTimeMs = TimeUnit.MILLISECONDS.toMillis(100);
private long maxRetryWaitTimeMs = TimeUnit.SECONDS.toMillis(20);
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 01391ffc51..819fcf2422 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
@@ -64,7 +64,7 @@ public class DataRegionStateMachine extends BaseStateMachine {
private DataRegion region;
- private static final int MAX_REQUEST_CACHE_SIZE = 1;
+ private static final int MAX_REQUEST_CACHE_SIZE = 5;
private static final long CACHE_WINDOW_TIME_IN_MS = 10_000;
private final PriorityQueue<InsertNodeWrapper> requestCache;