Repository: storm Updated Branches: refs/heads/1.x-branch 39e8f0e9c -> a7370a62f
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/6057fbf6 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/6057fbf6 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/6057fbf6 Branch: refs/heads/1.x-branch Commit: 6057fbf6f98f6916917716f57fbe3f473f655b6e Parents: a240df5 Author: Derek Dagit <[email protected]> Authored: Mon Apr 4 13:24:21 2016 -0500 Committer: Derek Dagit <[email protected]> Committed: Mon Apr 4 13:24:21 2016 -0500 ---------------------------------------------------------------------- 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/6057fbf6/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 c35e051..1ab2d33 100644 --- a/storm-core/src/clj/org/apache/storm/ui/core.clj +++ b/storm-core/src/clj/org/apache/storm/ui/core.clj @@ -109,14 +109,6 @@ [topology ^ExecutorSummary s] (component-type topology (.get_component_id s))) -(defn is-ack-stream - [stream] - (let [acker-streams - [ACKER-INIT-STREAM-ID - ACKER-ACK-STREAM-ID - ACKER-FAIL-STREAM-ID]] - (every? #(not= %1 stream) acker-streams))) - (defn spout-summary? [topology s] (= :spout (executor-summary-type topology s))) @@ -272,7 +264,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))))
