[jira] [Updated] (STORM-747) assignment-version-callback/info-with-version-callback are not fired when assignments change

["P. Taylor Goetz (JIRA)" <ji...@apache.org>]

     [ 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)