[
https://issues.apache.org/jira/browse/FLINK-32763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783074#comment-17783074
]
Yao Zhang commented on FLINK-32763:
-----------------------------------
Hi community,
I got the same issue and wanna work on it.
Could someone please assign this issue to me?
> Uncaught exceptions cause retry not to take effect in SocketTextStreamFunction
> ------------------------------------------------------------------------------
>
> Key: FLINK-32763
> URL: https://issues.apache.org/jira/browse/FLINK-32763
> Project: Flink
> Issue Type: Bug
> Components: API / DataStream
> Affects Versions: 1.17.1
> Environment: jdk 1.8.0_161
> Reporter: jianfeng miao
> Priority: Major
> Fix For: 1.17.1
>
>
> Uncaught exceptions cause retry not to take effect in SocketTextStreamFunction
>
> Caused by: java.net.ConnectException: Connection refused: connect
> at java.net.DualStackPlainSocketImpl.connect0(Native Method)
> at
> java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:79)
> at
> java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:345)
> at
> java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
> at
> java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
> at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172)
> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
> at java.net.Socket.connect(Socket.java:589)
> at
> org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction.run(SocketTextStreamFunction.java:104)
> at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110)
> at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67)
> at
> org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:323)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
