zhangjinlong created STORM-527:
----------------------------------
Summary: update worker.clj -- delete "missing-tasks" checking
Key: STORM-527
URL: https://issues.apache.org/jira/browse/STORM-527
Project: Apache Storm
Issue Type: Bug
Affects Versions: 0.9.3
Reporter: zhangjinlong
Fix For: 0.9.3
missing-tasks set is created by two times filter my-assignment map, so i think
keys(my-assignment) contains missing-tasks set.
missing-tasks is always empty. (empty? missing-tasks) always return true.
(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))
))
https://github.com/apache/storm/commit/4b65d8152527f6770db6d103a7e2950f1a1f5f91
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
