[FLUME-1084] NetcatSource stop() function returns when client still connected to the source, and can still write to it.

• Type: Bug
• Status: Patch Available
• Priority: Major
• Resolution: Unresolved
• Component/s: Sinks+Sources
• Assignee: Hari Shreedharan
• Reporter: Hari Shreedharan
• Created: 30/Mar/12 19:24
• Updated: 02/Apr/12 23:15

Description

Previous behavior(commit: 48edaf2) :

• netcat source runner.stop blocked till the accept handler exited when the nc client connected to it closed the connection
  (logs: [DEBUG - org.apache.flume.source.NetcatSource.stop(NetcatSource.java:208)] Waiting for handler service to stop)

New behavior(commit: 39aba18):

• netcat source runner.stop returns but a connected a client can still write to it, while a new source started up for the same agent due to reconfiguration. Note that a new client can startup on the same port as the old netcat source with no bind exception.