You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2015/10/20 15:23:41 UTC
[2/4] storm git commit: The system components are of type bolts
The system components are of type bolts
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/88bfa5af
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/88bfa5af
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/88bfa5af
Branch: refs/heads/master
Commit: 88bfa5af12ec07c0fb4c2d4a66f1812fee004edf
Parents: 8281115
Author: Kishor Patil <kp...@yahoo-inc.com>
Authored: Wed Oct 14 18:46:32 2015 +0000
Committer: Kishor Patil <kp...@yahoo-inc.com>
Committed: Wed Oct 14 18:46:32 2015 +0000
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/stats.clj | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/88bfa5af/storm-core/src/clj/backtype/storm/stats.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/stats.clj b/storm-core/src/clj/backtype/storm/stats.clj
index 7310f2c..dabc6f7 100644
--- a/storm-core/src/clj/backtype/storm/stats.clj
+++ b/storm-core/src/clj/backtype/storm/stats.clj
@@ -883,6 +883,7 @@
(let [bolts (.get_bolts topology)
spouts (.get_spouts topology)]
(cond
+ (Utils/isSystemId id) :bolt
(.containsKey bolts id) :bolt
(.containsKey spouts id) :spout)))