Hello, I'm trying to understand how Storm workers reconnect in case if some of their peers were reassigned
In the code I see this: https://github.com/apache/storm/blob/v0.9.5/storm-core/src/clj/backtype/storm/daemon/worker.clj#L483 (I'm looking into 0.9.5 code, but it seems master does not differ here). Every "task.refresh.poll.secs" worker connections are refreshed - so far so good. What confuses me is this comment: https://github.com/apache/storm/blob/v0.9.5/storm-core/src/jvm/backtype/storm/Config.java#L512. It states that reconnection also happens almost immediately after reassignment, so the periodic refresh is just a fallback. Is that comment outdated or am I missing some other way Storm uses to detect when to reconnect (e. g. watching assignments node in ZK)? Pointers to code are appreciated. Thanks, Yury
