hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ecl...@apache.org
Subject hbase git commit: HBASE-14313 After a Connection sees ConnectionClosingException on a connection it never recovers
Date Wed, 26 Aug 2015 20:47:32 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1.1 ae5439051 -> 0e4aabf99


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/0e4aabf9
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/0e4aabf9
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/0e4aabf9

Branch: refs/heads/branch-1.1
Commit: 0e4aabf99b341e8bfa6cd55ca4182e3e1dbd42cc
Parents: ae54390
Author: Elliott Clark <eclark@apache.org>
Authored: Tue Aug 25 18:39:31 2015 -0700
Committer: Elliott Clark <eclark@apache.org>
Committed: Wed Aug 26 13:44:49 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/0e4aabf9/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 4b96e31..a2d7172 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
@@ -935,7 +935,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();
         }


Mime
View raw message