(cherry picked from commit be80334cdf255616f589217726483194fb56dcc6)
@@ -207,6 +207,11 @@ public class DecommissioningNodesWatcher {
}
+ public void stop() {
+ pollTimer.cancel();
+ pollTimer = null;
+ }
+
/**
* Status about a specific decommissioning node.
*
@@ -263,6 +263,7 @@ public class ResourceTrackerService extends AbstractService implements
@Override
protected void serviceStop() throws Exception {
+ decommissioningWatcher.stop();
if (this.server != null) {
this.server.stop();