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)
