Repository: storm Updated Branches: refs/heads/master ce36b6dbf -> e6b57ce4b
only check non-system streams by default Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/e5ed7ffe Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/e5ed7ffe Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/e5ed7ffe Branch: refs/heads/master Commit: e5ed7ffe5a81e3c6ecf106f21cc84dd2bbe0a927 Parents: f631516 Author: Derek Dagit <[email protected]> Authored: Mon Apr 4 13:24:21 2016 -0500 Committer: Derek Dagit <[email protected]> Committed: Wed Apr 6 11:20:24 2016 -0700 ---------------------------------------------------------------------- storm-core/src/clj/org/apache/storm/ui/core.clj | 12 +++--------- 1 file changed, 3 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/e5ed7ffe/storm-core/src/clj/org/apache/storm/ui/core.clj ---------------------------------------------------------------------- diff --git a/storm-core/src/clj/org/apache/storm/ui/core.clj b/storm-core/src/clj/org/apache/storm/ui/core.clj index 885d754..17d9205 100644 --- a/storm-core/src/clj/org/apache/storm/ui/core.clj +++ b/storm-core/src/clj/org/apache/storm/ui/core.clj @@ -112,14 +112,6 @@ [topology ^ExecutorSummary s] (StatsUtil/componentType topology (.get_component_id s))) -(defn is-ack-stream - [stream] - (let [acker-streams - [Acker/ACKER_INIT_STREAM_ID - Acker/ACKER_ACK_STREAM_ID - Acker/ACKER_FAIL_STREAM_ID]] - (every? #(not= %1 stream) acker-streams))) - (defn spout-summary? [topology s] (= "spout" (executor-summary-type topology s))) @@ -283,7 +275,9 @@ (for [m (get v :inputs)] {:stream (get m :stream) :sani-stream (get m :sani-stream) - :checked (is-ack-stream (get m :stream))}))))))] + :checked (not + (Utils/isSystemId + (get m :stream)))}))))))] (map (fn [row] {:row row}) (partition 4 4 nil streams))))
