(cherry picked from commit 39c1ea1ed454b6c61f0985fc951f20913ed964fb)
@@ -311,8 +311,8 @@ public class NodeStatusUpdaterImpl extends AbstractService implements
statusUpdater.join();
registerWithRM();
statusUpdater = new Thread(statusUpdaterRunnable, "Node Status Updater");
- statusUpdater.start();
this.isStopped = false;
+ statusUpdater.start();
LOG.info("NodeStatusUpdater thread is reRegistered and restarted");
} catch (Exception e) {
String errorMessage = "Unexpected error rebooting NodeStatusUpdater";