diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ozoneimpl/OzoneContainer.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ozoneimpl/OzoneContainer.java index c9d645f15023..41779812495a 100644 --- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ozoneimpl/OzoneContainer.java +++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ozoneimpl/OzoneContainer.java @@ -37,7 +37,6 @@ import org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.ContainerReplicaProto; import org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.IncrementalContainerReportProto; import org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.PipelineReportsProto; -import org.apache.hadoop.hdds.ratis.RatisHelper; import org.apache.hadoop.hdds.security.token.TokenVerifier; import org.apache.hadoop.hdds.security.x509.SecurityConfig; import org.apache.hadoop.hdds.security.x509.certificate.client.CertificateClient; @@ -174,14 +173,16 @@ public OzoneContainer( new BlockDeletingService(this, svcInterval.toMillis(), serviceTimeout, TimeUnit.MILLISECONDS, config); - List< X509Certificate > x509Certificates = null; - if (certClient != null) { - x509Certificates = HAUtils.buildCAX509List(certClient, conf); + if (certClient != null && secConf.isGrpcTlsEnabled()) { + List x509Certificates = + HAUtils.buildCAX509List(certClient, conf); + tlsClientConfig = new GrpcTlsConfig( + certClient.getPrivateKey(), certClient.getCertificate(), + x509Certificates, true); + } else { + tlsClientConfig = null; } - tlsClientConfig = RatisHelper.createTlsClientConfig(secConf, - x509Certificates); - initializingStatus = new AtomicReference<>(InitializingStatus.UNINITIALIZED); }