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

["Mansheng Yang (JIRA)" <ji...@apache.org>]

Mansheng Yang created STORM-747:
-----------------------------------

             Summary: 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


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)