【详述】通过vpn,本地idea写的flinkjob将数据写入starrocks,报错:连接超时com.starrocks.shade.org.apache.http.conn.HttpHostConnectException: Connect to 172.30.16.26:18040 [/172.30.16.26] failed: Connection timed out: connect
【背景】将代码打包,放到starrocks的云服务器上运行就正常
【业务影响】
【StarRocks版本】2.5.2
【集群规模】例如：3fe（1 follower+2observer）+3be（fe与be混部）
【表模型】例如：主键模型
【导入或者导出方式】例如：Flink
【联系方式】微信:15818671016 邮箱:392388393@qq.com
【附件】
com.starrocks.shade.org.apache.http.conn.HttpHostConnectException: Connect to 172.30.16.26:18040 [/172.30.16.26] failed: Connection timed out: connect
at com.starrocks.shade.org.apache.http.impl.conn.DefaultHttpClientConnectionOperator.connect(DefaultHttpClientConnectionOperator.java:159)
at com.starrocks.shade.org.apache.http.impl.conn.PoolingHttpClientConnectionManager.connect(PoolingHttpClientConnectionManager.java:359)
at com.starrocks.shade.org.apache.http.impl.execchain.MainClientExec.establishRoute(MainClientExec.java:381)
at com.starrocks.shade.org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:237)
at com.starrocks.shade.org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:185)
at com.starrocks.shade.org.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:89)
at com.starrocks.shade.org.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:111)
at com.starrocks.shade.org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185)
at com.starrocks.shade.org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83)
at com.starrocks.shade.org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:108)
at com.starrocks.connector.flink.manager.StarRocksStreamLoadVisitor.doHttpPut(StarRocksStreamLoadVisitor.java:179)
at com.starrocks.connector.flink.manager.StarRocksStreamLoadVisitor.doStreamLoad(StarRocksStreamLoadVisitor.java:79)
at com.starrocks.connector.flink.manager.StarRocksSinkManager.asyncFlush(StarRocksSinkManager.java:258)
at com.starrocks.connector.flink.manager.StarRocksSinkManager.access$000(StarRocksSinkManager.java:52)
at com.starrocks.connector.flink.manager.StarRocksSinkManager$1.run(StarRocksSinkManager.java:120)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.net.ConnectException: Connection timed out: connect
at java.net.DualStackPlainSocketImpl.connect0(Native Method)
at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:79)
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.PlainSocketImpl.connect(PlainSocketImpl.java:172)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at com.starrocks.shade.org.apache.http.conn.socket.PlainConnectionSocketFactory.connectSocket(PlainConnectionSocketFactory.java:75)
at com.starrocks.shade.org.apache.http.impl.conn.DefaultHttpClientConnectionOperator.connect(DefaultHttpClientConnectionOperator.java:142)
… 15 more
flink的starrocks的依赖
com.starrocks
flink-connector-starrocks
1.1.10_flink-1.13
本地测试需要能连接be的8040端口，写入提交到fe会redirect到be
我之前改过用8040端口(安装时将8040改为18040了),也是连接超时.后来修改了fe.conf配置,启动远程写入功能,再按你说的用8040端口就可以了,谢谢!