From e182fadf042203a3eb7d4e2600dfe977dfbe1b7b Mon Sep 17 00:00:00 2001 From: zhangduo Date: Mon, 20 Mar 2017 21:06:06 +0800 Subject: [PATCH] HBASE-17812 Remove RpcConnection from pool in AbstractRpcClient.cancelConnections --- .../src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java | 1 + 1 file changed, 1 insertion(+) diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java index 4df6786..930f37a 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java @@ -444,6 +444,7 @@ public abstract class AbstractRpcClient implements RpcC && remoteId.address.getHostName().equals(sn.getHostname())) { LOG.info("The server on " + sn.toString() + " is dead - stopping the connection " + connection.remoteId); + connections.removeValue(remoteId, connection); connection.shutdown(); } } -- 1.9.1