HBASE-17812 Remove RpcConnection from pool in AbstractRpcClient.cancelConnections
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/cc59fe4e Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/cc59fe4e Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/cc59fe4e Branch: refs/heads/hbase-12439 Commit: cc59fe4e91ab0099f65566bc90e77e37f8147119 Parents: 7bb0624 Author: zhangduo <zhang...@apache.org> Authored: Mon Mar 20 21:06:06 2017 +0800 Committer: zhangduo <zhang...@apache.org> Committed: Tue Mar 21 10:07:16 2017 +0800 ---------------------------------------------------------------------- .../main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/cc59fe4e/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java ---------------------------------------------------------------------- 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<T extends RpcConnection> 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(); } }
