From ba8f9d6684928d23f2db90dcdee801ae591f113a Mon Sep 17 00:00:00 2001 From: Potato Date: Tue, 17 Dec 2024 10:13:34 +0800 Subject: [PATCH] Fix ratis byte limit configuration too small (#14449) Signed-off-by: OneSizeFitQuorum --- .../java/org/apache/iotdb/consensus/ratis/utils/Utils.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/utils/Utils.java b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/utils/Utils.java index 367b330ac3ec..bb32631a1b4e 100644 --- a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/utils/Utils.java +++ b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/utils/Utils.java @@ -310,7 +310,8 @@ public static void initRatisConfig(RaftProperties properties, RatisConfig config properties, RaftServerConfigKeys.Log.CorruptionPolicy.WARN_AND_RETURN); RaftServerConfigKeys.Write.setByteLimit( - properties, config.getLeaderLogAppender().getBufferByteLimit()); + properties, + SizeInBytes.valueOf(config.getLeaderLogAppender().getBufferByteLimit().getSize() * 10)); RaftServerConfigKeys.Log.setQueueByteLimit( properties, config.getLeaderLogAppender().getBufferByteLimit());