Repository: storm Updated Branches: refs/heads/1.x-branch 2d9f9036f -> eac26a7ae
STORM-1604:Delayed transition should handle NotALeaderException Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/26b74e16 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/26b74e16 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/26b74e16 Branch: refs/heads/1.x-branch Commit: 26b74e168aa1e25bd9f40afd935992e722dae275 Parents: e5c23a9 Author: Parth Brahmbhatt <[email protected]> Authored: Fri Mar 4 16:09:09 2016 -0800 Committer: Parth Brahmbhatt <[email protected]> Committed: Mon Mar 21 14:40:28 2016 -0700 ---------------------------------------------------------------------- storm-core/src/clj/org/apache/storm/daemon/nimbus.clj | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/26b74e16/storm-core/src/clj/org/apache/storm/daemon/nimbus.clj ---------------------------------------------------------------------- diff --git a/storm-core/src/clj/org/apache/storm/daemon/nimbus.clj b/storm-core/src/clj/org/apache/storm/daemon/nimbus.clj index ec5a624..2d8a684 100644 --- a/storm-core/src/clj/org/apache/storm/daemon/nimbus.clj +++ b/storm-core/src/clj/org/apache/storm/daemon/nimbus.clj @@ -373,8 +373,8 @@ (log-message "Delaying event " event " for " delay-secs " secs for " storm-id) (schedule (:timer nimbus) delay-secs - #(transition! nimbus storm-id event false) - )) + #(try (transition! nimbus storm-id event false) + (catch Exception e (log-error e "Exception while trying transition for " storm-id " and event " event))))) ;; active -> reassign in X secs
