This is an automated email from the ASF dual-hosted git repository.
ivandika pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 2a61f3281b HDDS-12291. XceiverClientRatis allows adding ratis data
stream configuration (#7842)
2a61f3281b is described below
commit 2a61f3281b46220f039b79284db25732e4fd6504
Author: XiChen <[email protected]>
AuthorDate: Tue Feb 11 09:06:20 2025 +0800
HDDS-12291. XceiverClientRatis allows adding ratis data stream
configuration (#7842)
---
.../src/main/java/org/apache/hadoop/hdds/ratis/RatisHelper.java | 6 +++++-
1 file changed, 5 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 d7afe8ed02..12a454de4a 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) &&
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
