You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2016/03/31 20:21:54 UTC
[3/5] storm git commit: STORM-1666: Kill from the UI fails silently
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 <ev...@yahoo-inc.com>
Authored: Wed Mar 30 14:30:19 2016 -0500
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
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