[ 
https://issues.apache.org/jira/browse/SPARK-12513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15070548#comment-15070548
 ] 

Shawn Guo commented on SPARK-12513:
-----------------------------------

Close client side socket connection before restart socket receiver.
https://github.com/apache/spark/pull/10464

> SocketReceiver hang in Netcat example
> -------------------------------------
>
>                 Key: SPARK-12513
>                 URL: https://issues.apache.org/jira/browse/SPARK-12513
>             Project: Spark
>          Issue Type: Bug
>          Components: Streaming
>    Affects Versions: 1.5.2
>            Reporter: Shawn Guo
>            Priority: Minor
>
> 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.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to