diff --git a/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientGrpc.java b/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientGrpc.java index c4680565477..048eab95fa7 100644 --- a/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientGrpc.java +++ b/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientGrpc.java @@ -191,6 +191,7 @@ protected NettyChannelBuilder createChannel(DatanodeDetails dn, int port) NettyChannelBuilder channelBuilder = NettyChannelBuilder.forAddress(dn.getIpAddress(), port).usePlaintext() .maxInboundMessageSize(OzoneConsts.OZONE_SCM_CHUNK_MAX_SIZE) + .proxyDetector(uri -> null) .intercept(new GrpcClientInterceptor()); if (secConfig.isSecurityEnabled() && secConfig.isGrpcTlsEnabled()) { SslContextBuilder sslContextBuilder = GrpcSslContexts.forClient(); diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/replication/GrpcReplicationClient.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/replication/GrpcReplicationClient.java index ad4f4293b91..dd741ec25d4 100644 --- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/replication/GrpcReplicationClient.java +++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/replication/GrpcReplicationClient.java @@ -74,7 +74,8 @@ public GrpcReplicationClient( NettyChannelBuilder channelBuilder = NettyChannelBuilder.forAddress(host, port) .usePlaintext() - .maxInboundMessageSize(OzoneConsts.OZONE_SCM_CHUNK_MAX_SIZE); + .maxInboundMessageSize(OzoneConsts.OZONE_SCM_CHUNK_MAX_SIZE) + .proxyDetector(uri -> null); if (secConfig.isSecurityEnabled() && secConfig.isGrpcTlsEnabled()) { channelBuilder.useTransportSecurity(); diff --git a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ha/InterSCMGrpcClient.java b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ha/InterSCMGrpcClient.java index eebcfac03c7..484e18902c5 100644 --- a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ha/InterSCMGrpcClient.java +++ b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ha/InterSCMGrpcClient.java @@ -67,7 +67,8 @@ public InterSCMGrpcClient(final String host, TimeUnit.MILLISECONDS); NettyChannelBuilder channelBuilder = NettyChannelBuilder.forAddress(host, port).usePlaintext() - .maxInboundMessageSize(OzoneConsts.OZONE_SCM_CHUNK_MAX_SIZE); + .maxInboundMessageSize(OzoneConsts.OZONE_SCM_CHUNK_MAX_SIZE) + .proxyDetector(uri -> null); SecurityConfig securityConfig = new SecurityConfig(conf); if (securityConfig.isSecurityEnabled() && securityConfig.isGrpcTlsEnabled()) { diff --git a/hadoop-ozone/common/src/main/java/org/apache/hadoop/ozone/om/protocolPB/GrpcOmTransport.java b/hadoop-ozone/common/src/main/java/org/apache/hadoop/ozone/om/protocolPB/GrpcOmTransport.java index 96f7b48665c..ac2e85da84d 100644 --- a/hadoop-ozone/common/src/main/java/org/apache/hadoop/ozone/om/protocolPB/GrpcOmTransport.java +++ b/hadoop-ozone/common/src/main/java/org/apache/hadoop/ozone/om/protocolPB/GrpcOmTransport.java @@ -145,6 +145,7 @@ public void start() throws IOException { NettyChannelBuilder channelBuilder = NettyChannelBuilder.forAddress(hp.getHost(), hp.getPort()) .usePlaintext() + .proxyDetector(uri -> null) .maxInboundMessageSize(maxSize); if (secConfig.isSecurityEnabled() && secConfig.isGrpcTlsEnabled()) { diff --git a/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/freon/FollowerAppendLogEntryGenerator.java b/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/freon/FollowerAppendLogEntryGenerator.java index d76081fd29e..76ef7888d0a 100644 --- a/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/freon/FollowerAppendLogEntryGenerator.java +++ b/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/freon/FollowerAppendLogEntryGenerator.java @@ -168,7 +168,8 @@ public Void call() throws Exception { .build(); NettyChannelBuilder channelBuilder = - NettyChannelBuilder.forTarget(serverAddress); + NettyChannelBuilder.forTarget(serverAddress) + .proxyDetector(uri -> null); channelBuilder.negotiationType(NegotiationType.PLAINTEXT); ManagedChannel build = channelBuilder.build(); stub = RaftServerProtocolServiceGrpc.newStub(build); diff --git a/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/freon/LeaderAppendLogEntryGenerator.java b/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/freon/LeaderAppendLogEntryGenerator.java index 40f67026032..9038f379186 100644 --- a/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/freon/LeaderAppendLogEntryGenerator.java +++ b/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/freon/LeaderAppendLogEntryGenerator.java @@ -144,7 +144,7 @@ public Void call() throws Exception { .build(); NettyChannelBuilder channelBuilder = - NettyChannelBuilder.forTarget(serverAddress); + NettyChannelBuilder.forTarget(serverAddress).proxyDetector(uri -> null); channelBuilder.negotiationType(NegotiationType.PLAINTEXT); ManagedChannel build = channelBuilder.build(); stub = RaftServerProtocolServiceGrpc.newStub(build);