[
https://issues.apache.org/jira/browse/STORM-954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699992#comment-14699992
]
ASF GitHub Bot commented on STORM-954:
--------------------------------------
Github user Parth-Brahmbhatt commented on a diff in the pull request:
https://github.com/apache/storm/pull/673#discussion_r37221221
--- Diff: storm-core/src/clj/backtype/storm/daemon/nimbus.clj ---
@@ -1159,6 +1161,18 @@
(check-authorization! nimbus storm-name topology-conf
"deactivate"))
(transition-name! nimbus storm-name :inactivate true))
+ (debug [this storm-name component-id enable?]
+ (let [storm-cluster-state (:storm-cluster-state nimbus)
+ storm-id (get-storm-id storm-cluster-state storm-name)
+ topology-conf (try-read-storm-conf conf storm-id)
+ storm-base-updates (assoc {} :component->debug (if (empty?
component-id) {storm-id enable?} {component-id enable?}))]
+ (check-authorization! nimbus storm-name topology-conf "debug")
+ (when-not storm-id
+ (throw (NotAliveException. storm-name)))
+ (log-message "Nimbus setting debug to " enable? " for storm-name
" storm-name " storm-id " storm-id)
--- End diff --
The log statement should also include component names for which debug is
being enabled otherwise person reading the statement can falsely assume the
debug is being enabled for the whole topology.
> Toplogy Event Inspector
> -----------------------
>
> Key: STORM-954
> URL: https://issues.apache.org/jira/browse/STORM-954
> Project: Apache Storm
> Issue Type: Improvement
> Reporter: Sriharsha Chintalapani
> Assignee: Arun Mahadevan
>
> •Ability to view tuples flowing through the topology
> •Ability to turn on/off debug events without having to stop/restart topology
> •Default debug events is off
> •User should be able to select a specific Spout or Bolt and see incoming
> events and outgoing events
> •We could put a configurable numbers of events to view (e.g. last 100 events
> or last 1 minute)
> •Tuple stream to have following info
> •Message id, batch/transaction id, name/value pair, timestamp, acked (boolean)
> •All the above to be available from Storm UI
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
