[
https://issues.apache.org/jira/browse/STORM-1098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14994454#comment-14994454
]
ASF GitHub Bot commented on STORM-1098:
---------------------------------------
Github user Parth-Brahmbhatt commented on a diff in the pull request:
https://github.com/apache/storm/pull/862#discussion_r44189187
--- Diff: storm-core/src/clj/backtype/storm/daemon/nimbus.clj ---
@@ -814,6 +816,11 @@
(.assignSlots inimbus topologies)))
(log-message "not a leader, skipping assignments")))
+(defn notify-topology-action-listener [nimbus storm-id action]
+ (let [topology-action-notifier (:nimbus-topology-action-notifier nimbus)]
+ (when (not-nil? topology-action-notifier)
+ (.notify topology-action-notifier storm-id action))))
--- End diff --
fixed.
> Storm Nimbus Hook
> -----------------
>
> Key: STORM-1098
> URL: https://issues.apache.org/jira/browse/STORM-1098
> Project: Apache Storm
> Issue Type: New Feature
> Components: storm-core
> Reporter: Sriharsha Chintalapani
> Assignee: Parth Brahmbhatt
>
> Apache Atlas provides governance services and also lineage. It will be great
> if we can capture the topology changes as part of Apache Atlas so that user
> can see how the topology changed over the period of time.
> Storm has ITaskHook but this is for topology components like spout & bolt.
> Similar to ITaskHook we should provide a nimbus hook that will allow
> pluggable implementations to run and can nimbus will execute this on any
> topology operation like upload jar, download, activate, deactivate , kill
> etc..
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
