You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ap...@apache.org on 2016/09/27 02:47:16 UTC
hbase git commit: HBASE-11354
HConnectionImplementation#DelayedClosing does not start (Qianxi Zhang and
Vincent Poon)
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 <ap...@apache.org>
Authored: Mon Sep 26 17:37:08 2016 -0700
Committer: Andrew Purtell <ap...@apache.org>
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) {