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