Skip to content


Subversion checkout URL

You can clone with
Download ZIP
Browse files

fixed bugs in transition function

  • Loading branch information...
commit 3cf6a95a3242d8d6bd74a6f78015311fa15e3d64 1 parent 52bea4f
@nathanmarz authored
Showing with 3 additions and 3 deletions.
  1. +3 −3 src/clj/backtype/storm/daemon/nimbus.clj
6 src/clj/backtype/storm/daemon/nimbus.clj
@@ -139,7 +139,7 @@
(transition! nimbus storm-id event false))
([nimbus storm-id event error-on-no-transition?]
(locking (:submit-lock nimbus)
- (let [[event event-args] (if (keyword? event) [event []] event)
+ (let [[event & event-args] (if (keyword? event) [event] event)
status (topology-status nimbus storm-id)]
(if status ; handles the case where event was scheduled but has been removed
(let [get-event (fn [m e]
@@ -148,10 +148,10 @@
(when error-on-no-transition?
(throw-runtime "No transition for event: " event
", status: " status,
- "storm-id: " storm-id)
+ " storm-id: " storm-id)
transition (-> (state-transitions nimbus storm-id status)
- (:type status)
+ (get (:type status))
(get-event event))
transition (if (or (nil? transition)
(keyword? transition))

0 comments on commit 3cf6a95

Please sign in to comment.
Something went wrong with that request. Please try again.