[GitHub] [incubator-seatunnel] Anxc520 opened a new issue #1540: Quick start-Flink-nc Stream demo:Error:Connection refused

Tue, 22 Mar 2022 07:18:42 -0700 


Anxc520 opened a new issue #1540:
URL: https://github.com/apache/incubator-seatunnel/issues/1540


   ### describe:
   官网-版本2.1-Quick start-Flink
   socket流 -> print
   source 配置需要添加host，如非本地运行。
   > https://seatunnel.apache.org/zh-CN/docs/2.1.0/flink/quick-start
   
   ### 问题代码：
   ```
   source {
       SocketStream{
             result_table_name = "fake"
             field_name = "info"
       }
   }
   ```
   修改为：
   ```
   source {
       SocketStream{
             result_table_name = "fake"
             field_name = "info"
             host = "你的实际IP"
       }
   }
   
   ```
   ### error code:
   >Caused by: java.net.ConnectException: 拒绝连接 (Connection refused)
        at java.net.PlainSocketImpl.socketConnect(Native Method)
        at 
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
        at 
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
        at 
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
        at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
        at java.net.Socket.connect(Socket.java:589)


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to