HBASE-14385 Close the sockets that is missing in connection closure.
This commit is contained in:
parent
7d018ec789
commit
1a19b0ee17
|
@ -873,6 +873,15 @@ public class RpcClientImpl extends AbstractRpcClient {
|
|||
}
|
||||
IOUtils.closeStream(in);
|
||||
this.in = null;
|
||||
if (this.socket != null) {
|
||||
try {
|
||||
this.socket.close();
|
||||
this.socket = null;
|
||||
} catch (IOException e) {
|
||||
LOG.error("Error while closing socket", e);
|
||||
}
|
||||
}
|
||||
|
||||
disposeSasl();
|
||||
|
||||
// log the info
|
||||
|
|
Loading…
Reference in New Issue