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 d7afe8ed0238..12a454de4ad5 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 @@ -367,7 +367,7 @@ public static void createRaftClientProperties(ConfigurationSource ozoneConf, getDatanodeRatisPrefixProps(ozoneConf); ratisClientConf.forEach((key, val) -> { if (isClientConfig(key) || isGrpcClientConfig(key) - || isNettyStreamConfig(key)) { + || isNettyStreamConfig(key) || isDataStreamConfig(key)) { raftProperties.set(key, val); } }); @@ -377,6 +377,10 @@ private static boolean isClientConfig(String key) { return key.startsWith(RaftClientConfigKeys.PREFIX); } + private static boolean isDataStreamConfig(String key) { + return key.startsWith(RaftConfigKeys.DataStream.PREFIX); + } + private static boolean isGrpcClientConfig(String key) { return key.startsWith(GrpcConfigKeys.PREFIX) && !key.startsWith(GrpcConfigKeys.TLS.PREFIX) &&