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 2014/06/11 18:09:41 UTC

[09/50] [abbrv] git commit: STORM-205. Add REST API to Storm UI. added complete-latencies to the topology-stats

STORM-205. Add REST API to Storm UI.
added complete-latencies to the topology-stats


Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/688444a9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/688444a9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/688444a9

Branch: refs/heads/security
Commit: 688444a96a5b2abf28faa0b7220e1436a0e951e3
Parents: 1333d48
Author: Sriharsha Chintalapani <ma...@harsha.io>
Authored: Wed May 28 20:14:12 2014 -0700
Committer: Sriharsha Chintalapani <ma...@harsha.io>
Committed: Wed May 28 20:14:12 2014 -0700

----------------------------------------------------------------------
 storm-core/src/clj/backtype/storm/ui/core.clj | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/688444a9/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 1e71923..d77ccb6 100644
--- a/storm-core/src/clj/backtype/storm/ui/core.clj
+++ b/storm-core/src/clj/backtype/storm/ui/core.clj
@@ -284,8 +284,8 @@
     (merge-with
      (fn [s1 s2]
        (merge-with + s1 s2))
-     (select-keys agg-bolt-stats [:emitted :transferred :acked :failed])
-     (select-keys agg-spout-stats [:emitted :transferred :acked :failed])
+     (select-keys agg-bolt-stats [:emitted :transferred :acked :failed :complete-latencies])
+     (select-keys agg-spout-stats [:emitted :transferred :acked :failed :complete-latencies])
      )))
 
 (defn stats-times [stats-map]