[
https://issues.apache.org/jira/browse/FLINK-21814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305386#comment-17305386
]
zhaoxing edited comment on FLINK-21814 at 3/20/21, 10:06 AM:
-------------------------------------------------------------
hi, [~Peihui]I [~jark] am willing to do it. Can you assign it to me? thank you
was (Author: zhaoxing):
hi, [~Peihui]I am willing to do it. Can you assign it to me? thank you
> flink CollectSink error info unfriendly
> ---------------------------------------
>
> Key: FLINK-21814
> URL: https://issues.apache.org/jira/browse/FLINK-21814
> Project: Flink
> Issue Type: Improvement
> Affects Versions: 1.12.2
> Reporter: Peihui He
> Priority: Minor
> Labels: pull-request-available
> Fix For: 1.12.3
>
>
> org.apache.flink.streaming.experimental.CollectSink initialization need host
> and port. When Network is unavailable, i will get the error:
> 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
>
> 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)
