You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by zh...@apache.org on 2018/06/25 06:15:28 UTC
hbase git commit: HBASE-20777 RpcConnection could still remain opened
after we shutdown the NettyRpcServer
Repository: hbase
Updated Branches:
refs/heads/master 7357b0ce9 -> 9640ebacd
HBASE-20777 RpcConnection could still remain opened after we shutdown the NettyRpcServer
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/9640ebac
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/9640ebac
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/9640ebac
Branch: refs/heads/master
Commit: 9640ebacd464049be5c04f5c2fb33a73603e8c34
Parents: 7357b0c
Author: zhangduo <zh...@apache.org>
Authored: Mon Jun 25 08:54:56 2018 +0800
Committer: zhangduo <zh...@apache.org>
Committed: Mon Jun 25 14:15:15 2018 +0800
----------------------------------------------------------------------
.../src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/9640ebac/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java
index fb2a8eb..8ea2057 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java
@@ -69,7 +69,8 @@ public class NettyRpcServer extends RpcServer {
private final CountDownLatch closed = new CountDownLatch(1);
private final Channel serverChannel;
- private final ChannelGroup allChannels = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);
+ private final ChannelGroup allChannels =
+ new DefaultChannelGroup(GlobalEventExecutor.INSTANCE, true);
public NettyRpcServer(Server server, String name, List<BlockingServiceAndInterface> services,
InetSocketAddress bindAddress, Configuration conf, RpcScheduler scheduler,