I add a SocketReceiver test based on the NetworkWordCount.
Using pipeline and tail the continuous output to netcat
tail -f xxx.log | nc -lk 9999
and create a SocketReceiver to receive the continuous output from remote netcat.
After about 10 hours, SocketReceiver hang and can not receive no more data.
Netcat only accept one socket connection and push "tail -f xxx.log" to connected socket. other connection is wating in the netcat queue.
When restart SocketReceive, new socket connection is created to connect to Netcat. However old connection is not closed properly. new connection can not read anything from Netcat.