[
https://issues.apache.org/jira/browse/FLINK-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327705#comment-14327705
]
ASF GitHub Bot commented on FLINK-1582:
---------------------------------------
GitHub user qmlmoon opened a pull request:
https://github.com/apache/flink/pull/424
[FLINK-1582][streaming]Allow SocketStream to reconnect when socket closes
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/qmlmoon/incubator-flink socket
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/424.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #424
----
commit fb9549ed3e56705cc01911dec80813c7db6452fa
Author: mingliang <qmlm...@gmail.com>
Date: 2015-02-19T15:53:32Z
[FLINK-1582][streaming]Allow SocketStream to reconnect when socket closes.
----
> SocketStream gets stuck when socket closes
> ------------------------------------------
>
> Key: FLINK-1582
> URL: https://issues.apache.org/jira/browse/FLINK-1582
> Project: Flink
> Issue Type: Bug
> Components: Streaming
> Affects Versions: 0.8, 0.9
> Reporter: Márton Balassi
> Labels: starter
>
> When the server side of the socket closes the socket stream reader does not
> terminate. When the socket is reinitiated it does not reconnect just gets
> stuck.
> It would be nice to add options for the user have the reader should behave
> when the socket is down: terminate immediately (good for testing and
> examples) or wait a specified time - possibly forever.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
