streamload通过集群虚拟ip导入数据,提示连接不上这是ip:8040服务器

【详述】
官网的java开发的StreamLoad例子,通过集群虚拟ip:172.17.9.191调用streamload导入数据,提示连接真实FE服务器ip192.168.2.190超时;

Exception in thread “main” org.apache.http.conn.HttpHostConnectException: Connect to 192.168.2.190:8040 [/192.168.2.190] failed: Connection timed out: connect
at org.apache.http.impl.conn.DefaultHttpClientConnectionOperator.connect(DefaultHttpClientConnectionOperator.java:156)
at org.apache.http.impl.conn.PoolingHttpClientConnectionManager.connect(PoolingHttpClientConnectionManager.java:376)
at org.apache.http.impl.execchain.MainClientExec.establishRoute(MainClientExec.java:393)
at org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:236)
at org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:186)
at org.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:89)
at org.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110)
at org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185)
at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83)
at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:108)
at org.casking.StarRocksStreamLoad.sendData(StarRocksStreamLoad.java:62)
at org.casking.StarRocksStreamLoad.main(StarRocksStreamLoad.java:102)
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 org.apache.http.conn.socket.PlainConnectionSocketFactory.connectSocket(PlainConnectionSocketFactory.java:75)
at org.apache.http.impl.conn.DefaultHttpClientConnectionOperator.connect(DefaultHttpClientConnectionOperator.java:142)
… 11 more

什么版本 ? 为什么会走虚拟ip导入数据呢

版本是:2.3.3, 因为权限管控的原因,对外只开放了虚拟ip地址;从外部访问不了FE的真实ip地址;

这个我理解当前不能指定给虚拟ip be的httpport端口能暴露出来吗 指定给 be也可以 就是指定给be不是很推荐,因为如果把导入作业请求发送给 FE,FE 会通过轮询机制选定由哪一个 BE 来接收请求,从而实现 StarRocks 集群内的负载均衡。如果是指定be接收的话,就只能写死了 ,固定给指定的be了 ,因此,还是推荐把导入作业请求发送给 FE的 可以的话可以申请下fe 的ip权限