Repository: hbase Updated Branches: refs/heads/branch-1.2 180e8b8fd -> 0a1f0cd66
HBASE-14313 After a Connection sees ConnectionClosingException on a connection it never recovers Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/0a1f0cd6 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/0a1f0cd6 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/0a1f0cd6 Branch: refs/heads/branch-1.2 Commit: 0a1f0cd66a0f090782726246d44d7e9c611abc68 Parents: 180e8b8 Author: Elliott Clark <ecl...@apache.org> Authored: Tue Aug 25 18:39:31 2015 -0700 Committer: Elliott Clark <ecl...@apache.org> Committed: Wed Aug 26 13:44:38 2015 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/hadoop/hbase/ipc/RpcClientImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/0a1f0cd6/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcClientImpl.java ---------------------------------------------------------------------- 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 5ece8ae..6647615 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(); }
