fix bug where a topology's status would get corrupted to true if nimbus is restarted while status is rebalancing or killed

Nathan Marz · Nathan Marz · commit 37313e4893a0 · 2012-07-31T17:41:21.000-07:00
diff --git a/src/clj/backtype/storm/daemon/nimbus.clj b/src/clj/backtype/storm/daemon/nimbus.clj
@@ -130,7 +130,8 @@
    :killed {:startup (fn [] (delay-event nimbus
                                          storm-id
                                          (:kill-time-secs status)
-                                         :remove))
+                                         :remove)
+                             nil)
             :kill (kill-transition nimbus storm-id)
             :remove (fn []
                       (log-message "Killing topology: " storm-id)
@@ -141,7 +142,8 @@
    :rebalancing {:startup (fn [] (delay-event nimbus
                                               storm-id
                                               (:delay-secs status)
-                                              :do-rebalance))
+                                              :do-rebalance)
+                                 nil)
                  :kill (kill-transition nimbus storm-id)
                  :do-rebalance (fn []
                                  (do-rebalance nimbus storm-id status)
