Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-20777 RpcConnection could still remain opened after we shutdown the NettyRpcServer

This commit is contained in:
zhangduo 2018-06-25 08:54:56 +08:00
parent 7357b0ce9f
commit 9640ebacd4
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java
View File

@ -69,7 +69,8 @@ public class NettyRpcServer extends RpcServer {
private final CountDownLatch closed = new CountDownLatch(1); private final CountDownLatch closed = new CountDownLatch(1);
private final Channel serverChannel; 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, public NettyRpcServer(Server server, String name, List<BlockingServiceAndInterface> services,
InetSocketAddress bindAddress, Configuration conf, RpcScheduler scheduler, InetSocketAddress bindAddress, Configuration conf, RpcScheduler scheduler,