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 d044026322e3..ca3170985ef2 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 @@ -256,6 +256,7 @@ private static void setClientTlsConf(Parameters parameters, GrpcTlsConfig tlsConfig) { if (tlsConfig != null) { GrpcConfigKeys.Client.setTlsConf(parameters, tlsConfig); + NettyConfigKeys.DataStream.Client.setTlsConf(parameters, tlsConfig); } } @@ -266,6 +267,8 @@ public static Parameters setServerTlsConf( GrpcConfigKeys.Server.setTlsConf(parameters, serverConf); GrpcConfigKeys.TLS.setConf(parameters, serverConf); setAdminTlsConf(parameters, serverConf); + + NettyConfigKeys.DataStream.Server.setTlsConf(parameters, serverConf); } setClientTlsConf(parameters, clientConf); return parameters;