[STORM-556] netty Client reconnect bug

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 0.9.2-incubating
• Fix Version/s: 0.9.3
• Component/s: storm-core
• Labels: ClientID hangup netty
• Assignee: Xavier Fu
• Reporter: Xavier Fu
• Created: 14/Nov/14 10:49
• Updated: 09/Oct/15 01:27
• Resolved: 09/Oct/15 01:27

Description

if a storm worker die then restarted and the nimbus reassign the task on the restarted worker with same host:port， the upstream task will not reconnect the host:port and the topology will hang up。

because the connect has broken and netty Client flush timer
if (null != channel && channel.isWritable()) {
flush(channel);
}
always false.