From 6031100cd75d33cbd5b74e2aabc222af330b6f32 Mon Sep 17 00:00:00 2001 From: guohao1 Date: Thu, 10 Feb 2022 20:55:26 +0800 Subject: [PATCH] HDDS-6298. Add XceiverServerRatis stream config --- .../java/org/apache/hadoop/hdds/ratis/RatisHelper.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/ratis/RatisHelper.java b/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/ratis/RatisHelper.java index e62fe8eb6dd2..0a1170417a6c 100644 --- a/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/ratis/RatisHelper.java +++ b/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/ratis/RatisHelper.java @@ -280,6 +280,10 @@ private static boolean isNettyStreamConfig(String key) { return key.startsWith(NettyConfigKeys.DataStream.PREFIX); } + private static boolean isStreamClientConfig(String key) { + return key.startsWith(RaftClientConfigKeys.DataStream.PREFIX); + } + /** * Set all server properties matching with prefix * {@link RatisHelper#HDDS_DATANODE_RATIS_PREFIX_KEY} in @@ -294,7 +298,8 @@ public static void createRaftServerProperties(ConfigurationSource ozoneConf, getDatanodeRatisPrefixProps(ozoneConf); ratisServerConf.forEach((key, val) -> { // Exclude ratis client configuration. - if (!isClientConfig(key)) { + if (isNettyStreamConfig(key) || isStreamClientConfig(key) || + !isClientConfig(key)) { raftProperties.set(key, val); } });