Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Duplicate
-
0.9.2-incubating
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.