flink-connector-starrocks 连接starRocks connect timed out

【详述】问题详细描述
flink 版本:14.2
flink-connector-starrocks版本:1.2.3_flink-1.14_2.12

使用flink-connector-starrocks 读取starRocks表中的数据,Failed to create brpc source:java.net.SocketTimeoutException: connect timed out

【背景】做过哪些操作?
开放brpc_port 端口,在windows本地能够telnet 通:
telnet 192.168.xxx.xxx 7030
7030是改过的,原生是8060
【业务影响】
【StarRocks版本】1.2.3
【集群规模】例如:3fe(1 follower+2observer)+5be(fe与be混部)
【机器信息】CPU虚拟核/内存/网卡,例如:48C/64G/万兆
【附件】

原因如下:starRocks是部署在阿里雲上,本地idea 通過公網ip請求be,因爲阿里雲的網咯架構,最後訪問的是阿里雲内網ip,所以會出現conect time out
debug 到StarRocksSourceBeReader 就清楚了

把包丢上去服务器上跑

报错提示有点误导分析问题,检查下 be-port 9060 端口 程序是否可以连接。

我这边报这个错,原因是阿里云安全组没有授权 9060 端口与网段,程序访问不了9060端口所致。

java.lang.RuntimeException: Failed to create brpc source:java.net.SocketTimeoutException: connect timed out 这个报错给人每一感觉是 be-brpc 8060 端口连接不上,其实是 be-port 9060 端口

可以在StartRocks节点抓包分析下:
tcpdump -s 0 -A 'tcp dst port 9060 and host 来源Flink服务器IP'

1赞

请问你是怎么解决的呢?我也遇到了

1赞

老哥,你这个问题解决了吗