diff --git hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionManager.java hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionManager.java index 53d6690..296eeaa 100644 --- hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionManager.java +++ hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionManager.java @@ -1626,8 +1626,9 @@ class ConnectionManager { @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) {