[
https://issues.apache.org/jira/browse/FLINK-21814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-21814.
---------------------------
Fix Version/s: (was: 1.12.3)
1.13.0
Assignee: Peihui He
Resolution: Fixed
Fixed in master: a33e6bd390a9935c3e25b6913bed0ff6b4a78818
> flink CollectSink error info unfriendly
> ---------------------------------------
>
> Key: FLINK-21814
> URL: https://issues.apache.org/jira/browse/FLINK-21814
> Project: Flink
> Issue Type: Improvement
> Components: API / DataStream, Table SQL / Ecosystem
> Affects Versions: 1.12.2
> Reporter: Peihui He
> Assignee: Peihui He
> Priority: Minor
> Labels: pull-request-available
> Fix For: 1.13.0
>
>
> org.apache.flink.streaming.experimental.CollectSink initialization need host
> and port. When Network is unavailable, i will get the error:
> {code}
> java.io.IOException: Cannot connect to the client to send back the stream
> at
> org.apache.flink.streaming.experimental.CollectSink.open(CollectSink.java:86)
> at
> org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)
> at
> org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102)
> at
> org.apache.flink.streaming.api.operators.StreamSink.open(StreamSink.java:46)
> at
> org.apache.flink.streaming.runtime.tasks.OperatorChain.initializeStateAndOpenOperators(OperatorChain.java:426)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$2(StreamTask.java:535)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:93)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:525)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:565)
> at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:755)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:570)
> at java.lang.Thread.run(Thread.java:748)
> Caused by: java.net.ConnectException: Connection refused (Connection refused)
> at java.net.PlainSocketImpl.socketConnect(Native Method)
> at
> java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:476)
> at
> java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:218)
> at
> java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:200)
> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:394)
> at java.net.Socket.connect(Socket.java:606)
> at java.net.Socket.connect(Socket.java:555)
> at java.net.Socket.<init>(Socket.java:451)
> at java.net.Socket.<init>(Socket.java:261)
> at
> org.apache.flink.streaming.experimental.CollectSink.open(CollectSink.java:82)
> ... 11 more
> {code}
>
> However, i couldn't know the host and port.
>
> Hope the error info could includ the host and port.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
