Github user nathanmarz commented on the pull request:
https://github.com/apache/storm/pull/349#issuecomment-87767343
Taking a look at it again, it looks like the introduction of
TransferDrainer is a regression. The way that class works doesn't make a whole
lot of sense... it has separate add and send methods but those are only ever
used in the same method. Looking up the node+port for the task should happen in
the read lock as well.
The send code should be updated to fix this.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
