[
https://issues.apache.org/jira/browse/STORM-747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
P. Taylor Goetz updated STORM-747:
----------------------------------
Fix Version/s: (was: 0.11.0)
0.10.0
> assignment-version-callback/info-with-version-callback are not fired when
> assignments change
> --------------------------------------------------------------------------------------------
>
> Key: STORM-747
> URL: https://issues.apache.org/jira/browse/STORM-747
> Project: Apache Storm
> Issue Type: Bug
> Reporter: Mansheng Yang
> Assignee: Mansheng Yang
> Priority: Minor
> Fix For: 0.10.0
>
>
> In cluster.clj, assignment-version-callback and
> assignment-info-with-version-callback are never fired when assignments
> change. These callbacks are used in the worker and expected to be called when
> the corresponding assignment changes.
> Starting from cluster.clj line 269:
> {code}
> (fn [type path]
> (let [[subtree & args] (tokenize-path path)]
> (condp = subtree
> ASSIGNMENTS-ROOT (if (empty? args)
> (issue-callback!
> assignments-callback)
> (issue-map-callback!
> assignment-info-callback (first args)))
> SUPERVISORS-ROOT (issue-callback!
> supervisors-callback)
> STORMS-ROOT (issue-map-callback! storm-base-callback
> (first args))
> CREDENTIALS-ROOT (issue-map-callback!
> credentials-callback (first args))
> {code}
> It is clear that only assignment-info-callback is fired
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
