(iotdb) branch fix_ratis_byte_limit created (now 1237de32da1)

[ta...@apache.org]

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

tanxinyu pushed a change to branch fix_ratis_byte_limit
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at 1237de32da1 fix ratis byte limit

This branch includes the following new commits:

     new 1237de32da1 fix ratis byte limit

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

(iotdb) 01/01: fix ratis byte limit

[ta...@apache.org]

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 <ta...@apache.org>
AuthorDate: Mon Dec 16 19:45:06 2024 +0800

    fix ratis byte limit
    
    Signed-off-by: OneSizeFitQuorum <ta...@apache.org>
---
 .../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());