From 9bf5990e262fbef243096c9864d8580237889185 Mon Sep 17 00:00:00 2001 From: Sergey Soldatov Date: Fri, 3 Jun 2016 13:13:25 -0700 Subject: HBASE-15957 RpcClientImpl.close never ends in some circumstances --- .../src/main/java/org/apache/hadoop/hbase/ipc/RpcClientImpl.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) 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 d8c87e9..dc05af1 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 @@ -1202,9 +1202,8 @@ public class RpcClientImpl extends AbstractRpcClient { } if (connsToClose != null) { for (Connection conn : connsToClose) { - if (conn.markClosed(new InterruptedIOException("RpcClient is closing"))) { - conn.close(); - } + conn.markClosed(new InterruptedIOException("RpcClient is closing")); + conn.close(); } } // wait until all connections are closed -- 2.5.4 (Apple Git-61)