[STORM-737] Workers may try to send to closed connections

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.9.2-incubating
• Fix Version/s: 0.10.0
• Component/s: storm-core
• Assignee: Jungtaek Lim
• Reporter: Derek Dagit
• Created: 30/Mar/15 18:59
• Updated: 05/Oct/15 00:55
• Resolved: 27/Jul/15 23:00

Description

There is a race condition in the worker code that can allow for a send() to be called on a closed connection.

Discussion

The assignment mapping from task -> node+port needs to be read and used in the read lock when sending, so that an accurate mapping is used that does not include any connections that are closed.

Issue Links

• is related to: STORM-770 NullPointerException in consumeBatchToCursor
• supercedes: STORM-593 No need of rwlock for clojure atom