Dear all,
These time i start reading the storm code, i found much duplicate or
useless code i think, just like "mk-refresh-connections" function in worker.clj:
(let [missing-tasks (->> needed-tasks
(filter (complement my-assignment)))]
(when-not (empty? missing-tasks)
(log-warn "Missing assignment for following tasks: " (pr-str missing-tasks))
))
the needed-tasks comes from my-assignment, of course every element can be found
in map my-assignment, why this code was added here?
Darwin
Best regards..
