This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch fix_ratis_byte_limit in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 1237de32da151842e9d2a2f00cb65a1cafe81820 Author: OneSizeFitQuorum <[email protected]> AuthorDate: Mon Dec 16 19:45:06 2024 +0800 fix ratis byte limit Signed-off-by: OneSizeFitQuorum <[email protected]> --- .../src/main/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 367b330ac3e..bb32631a1b4 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 class Utils { 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());
