STORM-1666: Kill from the UI fails silently
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/f807c80d Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/f807c80d Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/f807c80d Branch: refs/heads/master Commit: f807c80d9be1179e2d23cbc494aaa25fa57ff602 Parents: 08eb49e Author: Robert (Bobby) Evans <[email protected]> Authored: Wed Mar 30 14:30:19 2016 -0500 Committer: Robert (Bobby) Evans <[email protected]> Committed: Wed Mar 30 14:30:19 2016 -0500 ---------------------------------------------------------------------- storm-core/src/clj/org/apache/storm/daemon/nimbus.clj | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/f807c80d/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 8847d0d..743db77 100644 --- a/storm-core/src/clj/org/apache/storm/daemon/nimbus.clj +++ b/storm-core/src/clj/org/apache/storm/daemon/nimbus.clj @@ -1885,7 +1885,8 @@ executor-summaries (dofor [[executor [node port]] (:executor->node+port assignment)] (let [host (-> assignment :node->host (get node)) heartbeat (.get beats (StatsUtil/convertExecutor executor)) - excutorstats (.get (.get heartbeat "heartbeat") "stats") + hb (if heartbeat (.get heartbeat "heartbeat")) + excutorstats (if hb (.get hb "stats")) excutorstats (if excutorstats (StatsUtil/thriftifyExecutorStats excutorstats))] (doto
