You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2014/06/09 21:48:07 UTC
[3/4] git commit: Fix component links and cleanup
Fix component links and cleanup
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/b1537437
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/b1537437
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/b1537437
Branch: refs/heads/master
Commit: b15374372e777bf24e7117db41a38bb0c19223a1
Parents: 1e0413e
Author: Kyle Nusbaum <kn...@yahoo-inc.com>
Authored: Wed Jun 4 23:31:06 2014 +0000
Committer: Kyle Nusbaum <kn...@yahoo-inc.com>
Committed: Wed Jun 4 23:31:06 2014 +0000
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/ui/core.clj | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/b1537437/storm-core/src/clj/backtype/storm/ui/core.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/ui/core.clj b/storm-core/src/clj/backtype/storm/ui/core.clj
index 9914dff..5f2bcba 100644
--- a/storm-core/src/clj/backtype/storm/ui/core.clj
+++ b/storm-core/src/clj/backtype/storm/ui/core.clj
@@ -280,14 +280,12 @@
(map nil-to-zero)
(apply max)))
-;; Watch These
(defn spout-streams-stats [summs include-sys?]
(let [stats-seq (get-filled-stats summs)]
(aggregate-spout-streams
(aggregate-spout-stats
stats-seq include-sys?))))
-;; Watch These
(defn bolt-streams-stats [summs include-sys?]
(let [stats-seq (get-filled-stats summs)]
(aggregate-bolt-streams
@@ -381,7 +379,7 @@
(mapfn bolt-summs)
(mapfn spout-summs)))
- :link (url-format "/topology/%s/component/%s" storm-id id)
+ :link (url-format "/component.html?id=%s&topology_id=%s" id storm-id)
:inputs (for [[global-stream-id group] inputs]
{:component (.get_componentId global-stream-id)