This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 6616600fa5 [ISSUE #7791] Polish the code for jraft controller
6616600fa5 is described below
commit 6616600fa5e5f1426024ca9c40c12688c38edf9b
Author: rongtong <[email protected]>
AuthorDate: Fri Feb 2 12:33:22 2024 +0800
[ISSUE #7791] Polish the code for jraft controller
---
WORKSPACE | 2 +-
.../java/org/apache/rocketmq/common/JraftConfig.java | 16 ++++++++--------
2 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/WORKSPACE b/WORKSPACE
index 5880f9ca47..16f66b7325 100644
--- a/WORKSPACE
+++ b/WORKSPACE
@@ -107,7 +107,7 @@ maven_install(
"com.adobe.testing:s3mock-junit4:2.11.0",
"io.github.aliyunmq:rocketmq-grpc-netty-codec-haproxy:1.0.0",
"org.apache.rocketmq:rocketmq-rocksdb:1.0.2",
- "com.alipay.sofa:jraft-core:1.3.11",
+ "com.alipay.sofa:jraft-core:1.3.14",
"com.alipay.sofa:hessian:3.3.6",
"io.netty:netty-tcnative-boringssl-static:2.0.48.Final",
],
diff --git a/common/src/main/java/org/apache/rocketmq/common/JraftConfig.java
b/common/src/main/java/org/apache/rocketmq/common/JraftConfig.java
index 1bb3bf0298..072d0caf24 100644
--- a/common/src/main/java/org/apache/rocketmq/common/JraftConfig.java
+++ b/common/src/main/java/org/apache/rocketmq/common/JraftConfig.java
@@ -17,14 +17,14 @@
package org.apache.rocketmq.common;
public class JraftConfig {
- int jRaftElectionTimeoutMs = 1000;
-
- int jRaftScanWaitTimeoutMs = 1000;
- int jRaftSnapshotIntervalSecs = 3600;
- String jRaftGroupId = "jRaft-Controller";
- String jRaftServerId = "localhost:9880";
- String jRaftInitConf = "localhost:9880,localhost:9881,localhost:9882";
- String jRaftControllerRPCAddr =
"localhost:9770,localhost:9771,localhost:9772";
+ private int jRaftElectionTimeoutMs = 1000;
+
+ private int jRaftScanWaitTimeoutMs = 1000;
+ private int jRaftSnapshotIntervalSecs = 3600;
+ private String jRaftGroupId = "jRaft-Controller";
+ private String jRaftServerId = "localhost:9880";
+ private String jRaftInitConf =
"localhost:9880,localhost:9881,localhost:9882";
+ private String jRaftControllerRPCAddr =
"localhost:9770,localhost:9771,localhost:9772";
public int getjRaftElectionTimeoutMs() {
return jRaftElectionTimeoutMs;