You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ratis.apache.org by sz...@apache.org on 2020/11/10 16:54:33 UTC
[incubator-ratis] branch master updated: RATIS-1144. Default
disable datastream when start a MiniRaftCluster (#266)
This is an automated email from the ASF dual-hosted git repository.
szetszwo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-ratis.git
The following commit(s) were added to refs/heads/master by this push:
new 05eaa70 RATIS-1144. Default disable datastream when start a MiniRaftCluster (#266)
05eaa70 is described below
commit 05eaa70128dfa12dcfed459684983267cb079e92
Author: runzhiwang <51...@users.noreply.github.com>
AuthorDate: Wed Nov 11 00:50:48 2020 +0800
RATIS-1144. Default disable datastream when start a MiniRaftCluster (#266)
---
ratis-common/src/main/java/org/apache/ratis/RaftConfigKeys.java | 2 +-
.../src/test/java/org/apache/ratis/datastream/TestDataStreamNetty.java | 1 +
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/ratis-common/src/main/java/org/apache/ratis/RaftConfigKeys.java b/ratis-common/src/main/java/org/apache/ratis/RaftConfigKeys.java
index ede45cb..7c14a47 100644
--- a/ratis-common/src/main/java/org/apache/ratis/RaftConfigKeys.java
+++ b/ratis-common/src/main/java/org/apache/ratis/RaftConfigKeys.java
@@ -51,7 +51,7 @@ public interface RaftConfigKeys {
String PREFIX = RaftConfigKeys.PREFIX + ".datastream";
String TYPE_KEY = PREFIX + ".type";
- String TYPE_DEFAULT = SupportedDataStreamType.NETTY.name();
+ String TYPE_DEFAULT = SupportedDataStreamType.DISABLED.name();
static SupportedDataStreamType type(RaftProperties properties, Consumer<String> logger) {
final String t = get(properties::get, TYPE_KEY, TYPE_DEFAULT, logger);
diff --git a/ratis-test/src/test/java/org/apache/ratis/datastream/TestDataStreamNetty.java b/ratis-test/src/test/java/org/apache/ratis/datastream/TestDataStreamNetty.java
index 27a19a5..3a99815 100644
--- a/ratis-test/src/test/java/org/apache/ratis/datastream/TestDataStreamNetty.java
+++ b/ratis-test/src/test/java/org/apache/ratis/datastream/TestDataStreamNetty.java
@@ -96,6 +96,7 @@ public class TestDataStreamNetty extends DataStreamBaseTest {
RaftPeerId peerId = RaftPeerId.valueOf("s" + i);
RaftProperties properties = new RaftProperties();
NettyConfigKeys.DataStream.setPort(properties, NetUtils.createLocalServerAddress().getPort());
+ RaftConfigKeys.DataStream.setType(properties, SupportedDataStreamType.NETTY);
if (i == leaderIndex) {
raftClientReply = expectedClientReply;