HDDS-865. GrpcXceiverService is added twice to GRPC netty server. Contributed by Xiaoyu Yao.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/f42b2dfd Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/f42b2dfd Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/f42b2dfd Branch: refs/heads/HDDS-4 Commit: f42b2dfdf12c2f2a1952e2492f8d1b7b358013f6 Parents: 34b6fa7 Author: Shashikant Banerjee <[email protected]> Authored: Wed Nov 21 23:43:01 2018 +0530 Committer: Shashikant Banerjee <[email protected]> Committed: Wed Nov 21 23:43:01 2018 +0530 ---------------------------------------------------------------------- .../container/common/transport/server/XceiverServerGrpc.java | 4 ---- 1 file changed, 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/f42b2dfd/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/XceiverServerGrpc.java ---------------------------------------------------------------------- diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/XceiverServerGrpc.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/XceiverServerGrpc.java index be00c8a..4f7799d 100644 --- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/XceiverServerGrpc.java +++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/XceiverServerGrpc.java @@ -90,10 +90,6 @@ public final class XceiverServerGrpc implements XceiverServerSpi { } datanodeDetails.setPort( DatanodeDetails.newPort(DatanodeDetails.Port.Name.STANDALONE, port)); - server = ((NettyServerBuilder) ServerBuilder.forPort(port)) - .maxInboundMessageSize(OzoneConsts.OZONE_SCM_CHUNK_MAX_SIZE) - .addService(new GrpcXceiverService(dispatcher)) - .build(); NettyServerBuilder nettyServerBuilder = ((NettyServerBuilder) ServerBuilder.forPort(port)) .maxInboundMessageSize(OzoneConsts.OZONE_SCM_CHUNK_MAX_SIZE) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
