CDPD-72782. HDDS-11257. Ozone write does not work when http proxy is set for the JVM. (apache#7036) (apache#212)

(cherry picked from commit 6569278)

Co-authored-by: Sadanand Shenoy <sadanand.shenoy4898@gmail.com>

Author: 2 people

hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientGrpc.java

@@ -197,6 +197,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();

hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/replication/GrpcReplicationClient.java

@@ -75,7 +75,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();

hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ha/InterSCMGrpcClient.java

@@ -68,7 +68,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()) {

hadoop-ozone/common/src/main/java/org/apache/hadoop/ozone/om/protocolPB/GrpcOmTransport.java

@@ -141,6 +141,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()) {

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);

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);