From 2b6da527b31c70c5ec764e09b109fc4d3ab6704f Mon Sep 17 00:00:00 2001 From: Andrew Purtell Date: Mon, 26 Sep 2016 17:37:08 -0700 Subject: [PATCH] HBASE-11354 HConnectionImplementation#DelayedClosing does not start (Qianxi Zhang and Vincent Poon) --- .../main/java/org/apache/hadoop/hbase/client/HConnectionManager.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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) { -- 2.10.0