Mysql实时同步Starrocks

为了更快的定位您的问题,请提供以下信息,谢谢
【详述】导入表没问题,导入数据的时候会一直请求be的url 但是一直连接超时
Connect to kube-starrocks-be-0.kube-starrocks-be-search.default.svc.cluster.local:8040 [kube-starrocks-be-0.kube-starrocks-be-search.default.svc.cluster.local/我们的ip] failed: Connection timed out (Connection timed out)
【背景】执行./bin/sql-client.sh -f flink-create.all.sql
【业务影响】
【StarRocks版本】2.5.5
【集群规模】例如:1fe+1be(fe与be混部)
【机器信息】CPU虚拟核/内存/网卡,例如:16C/30G/万兆
【表模型】主键模型
【导入或者导出方式】Flink
【联系方式】为了在解决问题过程中能及时联系到您获取一些日志信息,请补充下您的联系方式,例如:2212322276@qq.com
【附件】


2023-09-07 23:44:48,413 WARN com.starrocks.connector.flink.manager.StarRocksSinkManager [] - Failed to flush batch data to StarRocks, retry times = 3

com.starrocks.shade.org.apache.http.conn.HttpHostConnectException: Connect to kube-starrocks-be-0.kube-starrocks-be-search.default.svc.cluster.local:8040 [kube-starrocks-be-0.kube-starrocks-be-search.default.svc.cluster.local/我们的ip] failed: Connection timed out (Connection timed out)

at com.starrocks.shade.org.apache.http.impl.conn.DefaultHttpClientConnectionOperator.connect(DefaultHttpClientConnectionOperator.java:156) ~[flink-connector-starrocks-1.2.3_flink-1.14_2.11.jar:?]

at com.starrocks.shade.org.apache.http.impl.conn.PoolingHttpClientConnectionManager.connect(PoolingHttpClientConnectionManager.java:376) ~[flink-connector-starrocks-1.2.3_flink-1.14_2.11.jar:?]

at com.starrocks.shade.org.apache.http.impl.execchain.MainClientExec.establishRoute(MainClientExec.java:393) ~[flink-connector-starrocks-1.2.3_flink-1.14_2.11.jar:?]

at com.starrocks.shade.org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:236) ~[flink-connector-starrocks-1.2.3_flink-1.14_2.11.jar:?]

at com.starrocks.shade.org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:186) ~[flink-connector-starrocks-1.2.3_flink-1.14_2.11.jar:?]

at com.starrocks.shade.org.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:89) ~[flink-connector-starrocks-1.2.3_flink-1.14_2.11.jar:?]

at com.starrocks.shade.org.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110) ~[flink-connector-starrocks-1.2.3_flink-1.14_2.11.jar:?]

at com.starrocks.shade.org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185) ~[flink-connector-starrocks-1.2.3_flink-1.14_2.11.jar:?]

at com.starrocks.shade.org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83) ~[flink-connector-starrocks-1.2.3_flink-1.14_2.11.jar:?]

at com.starrocks.shade.org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:108) ~[flink-connector-starrocks-1.2.3_flink-1.14_2.11.jar:?]

at com.starrocks.connector.flink.manager.StarRocksStreamLoadVisitor.doHttpPut(StarRocksStreamLoadVisitor.java:269) ~[flink-connector-starrocks-1.2.3_flink-1.14_2.11.jar:?]

at com.starrocks.connector.flink.manager.StarRocksStreamLoadVisitor.doStreamLoad(StarRocksStreamLoadVisitor.java:91) ~[flink-connector-starrocks-1.2.3_flink-1.14_2.11.jar:?]

at com.starrocks.connector.flink.manager.StarRocksSinkManager.asyncFlush(StarRocksSinkManager.java:316) ~[flink-connector-starrocks-1.2.3_flink-1.14_2.11.jar:?]

at com.starrocks.connector.flink.manager.StarRocksSinkManager.lambda$startAsyncFlushing$0(StarRocksSinkManager.java:160) ~