Repository: hbase
Updated Branches:
  refs/heads/0.98 821871966 -> 2b6da527b


HBASE-11354 HConnectionImplementation#DelayedClosing does not start (Qianxi 
Zhang and Vincent Poon)


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/2b6da527
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/2b6da527
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/2b6da527

Branch: refs/heads/0.98
Commit: 2b6da527b31c70c5ec764e09b109fc4d3ab6704f
Parents: 8218719
Author: Andrew Purtell <[email protected]>
Authored: Mon Sep 26 17:37:08 2016 -0700
Committer: Andrew Purtell <[email protected]>
Committed: Mon Sep 26 17:37:08 2016 -0700

----------------------------------------------------------------------
 .../java/org/apache/hadoop/hbase/client/HConnectionManager.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/2b6da527/hbase-client/src/main/java/org/apache/hadoop/hbase/client/HConnectionManager.java
----------------------------------------------------------------------
diff --git 
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/HConnectionManager.java
 
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/HConnectionManager.java
index 059ce58..4cafc41 100644
--- 
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/HConnectionManager.java
+++ 
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/HConnectionManager.java
@@ -1913,8 +1913,9 @@ public class HConnectionManager {
               @Override public void stop(String why) { isStopped = true;}
               @Override public boolean isStopped() {return isStopped;}
             };
-
-        return new DelayedClosing(hci, stoppable);
+        DelayedClosing delayedClosing = new DelayedClosing(hci, stoppable);
+        delayedClosing.start();
+        return delayedClosing;
       }
 
       protected void closeMasterProtocol(MasterServiceState protocolState) {

Reply via email to