From 56890d9fe148dd192520fab349a66aa3f688e232 Mon Sep 17 00:00:00 2001 From: Elliott Clark Date: Tue, 25 Aug 2015 18:39:31 -0700 Subject: [PATCH] HBASE-14313 After a Connection sees ConnectionClosingException on a connection it never recovers --- .../main/java/org/apache/hadoop/hbase/ipc/RpcClientImpl.java | 2 +- 1 file changed, 1 insertion(+), 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 5ece8ae5b08..664761566bc 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,7 @@ 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 - shouldCloseConnection.set(true); + markClosed(e); writeException = e; interrupt(); }