diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcClientImpl.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcClientImpl.java index cb189524e76..92ae24fd235 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcClientImpl.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcClientImpl.java @@ -923,9 +923,8 @@ public class RpcClientImpl extends AbstractRpcClient { // call close outside of the synchronized (outLock) to prevent deadlock - HBASE-14474 if (writeException != null) { - if (markClosed(writeException)) { - close(); - } + markClosed(writeException); + close(); } // We added a call, and may be started the connection close. In both cases, we