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

HBASE-14458 AsyncRpcClient#createRpcChannel() should check and remove dead channel before creating new one to same server (Samir Ahmic)

This commit is contained in:
tedyu 2015-10-18 20:49:31 -07:00
parent f1b6355fc5
commit 8e6316a80c
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AsyncRpcClient.java
View File

@ -386,7 +386,11 @@ public class AsyncRpcClient extends AbstractRpcClient {
throw new StoppedRpcClientException();
}
rpcChannel = connections.get(hashCode);
if (rpcChannel == null || !rpcChannel.isAlive()) {
if (rpcChannel != null && !rpcChannel.isAlive()) {
LOG.debug("Removing dead channel from server="+rpcChannel.address.toString());
connections.remove(hashCode);
}
if (rpcChannel == null) {
rpcChannel = new AsyncRpcChannel(this.bootstrap, this, ticket, serviceName, location);
connections.put(hashCode, rpcChannel);
}