This is an automated email from the ASF dual-hosted git repository.
adoroszlai 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 583fdb8e34 HDDS-7879. Intermittent BindException in HA integration
tests (#4241)
583fdb8e34 is described below
commit 583fdb8e34e14f54cdb5df908e185f346217de7a
Author: Doroszlai, Attila <[email protected]>
AuthorDate: Thu Feb 2 19:54:15 2023 +0100
HDDS-7879. Intermittent BindException in HA integration tests (#4241)
---
.../src/main/java/org/apache/hadoop/hdds/ratis/RatisHelper.java | 5 +++++
.../container/common/transport/server/ratis/XceiverServerRatis.java | 1 +
2 files changed, 6 insertions(+)
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 5b7ecb0c6b..84a882560b 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
@@ -237,6 +237,7 @@ public final class RatisHelper {
rpcType, leader, group);
}
final RaftProperties properties = newRaftProperties(rpcType);
+ enableNettyStreaming(properties);
// Set the ratis client headers which are matching with regex.
createRaftClientProperties(ozoneConfiguration, properties);
@@ -305,6 +306,10 @@ public final class RatisHelper {
public static RaftProperties setRpcType(RaftProperties properties,
RpcType rpcType) {
RaftConfigKeys.Rpc.setType(properties, rpcType);
+ return properties;
+ }
+
+ public static RaftProperties enableNettyStreaming(RaftProperties properties)
{
RaftConfigKeys.DataStream.setType(properties,
SupportedDataStreamType.NETTY);
return properties;
diff --git
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/XceiverServerRatis.java
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/XceiverServerRatis.java
index 89e5047b85..cceb78dff4 100644
---
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/XceiverServerRatis.java
+++
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/XceiverServerRatis.java
@@ -231,6 +231,7 @@ public final class XceiverServerRatis implements
XceiverServerSpi {
OzoneConfigKeys.DFS_CONTAINER_RATIS_DATASTREAM_PORT,
OzoneConfigKeys.DFS_CONTAINER_RATIS_DATASTREAM_PORT_DEFAULT);
}
+ RatisHelper.enableNettyStreaming(properties);
NettyConfigKeys.DataStream.setPort(properties, dataStreamPort);
int dataStreamAsyncRequestThreadPoolSize =
conf.getObject(DatanodeRatisServerConfig.class)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
