From 64ee06793c407de3b0c36a85810454ad78c00275 Mon Sep 17 00:00:00 2001 From: Elliott Clark Date: Wed, 26 Aug 2015 22:28:38 -0700 Subject: [PATCH] HBASE-14313 After a Connection sees ConnectionClosingException it never recovers -- ADDENDUM --- .../src/main/java/org/apache/hadoop/hbase/ipc/RpcClientImpl.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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 6647615..c11273e 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 @@ -939,7 +939,9 @@ public class RpcClientImpl extends AbstractRpcClient { } catch (IOException e) { // We set the value inside the synchronized block, this way the next in line // won't even try to write - markClosed(e); + if (markClosed(e)) { + close(); + } writeException = e; interrupt(); } -- 2.5.0