Flink CDC同步MySQL到StarRocks中无法连接BE或CN节点

【详述】搭建StarRocks实时同步Mysql组件,按照着Flink和StarRocks提供的官方文档执行到运行任务时,报错无法连接BE/CN节点
文档地址:https://nightlies.apache.org/flink/flink-cdc-docs-release-3.1/zh/docs/get-started/quickstart/mysql-to-starrocks/

我感觉和https://forum.mirrorship.cn/t/topic/5570是一个问题,但是我不知道怎么去修改重定向的host,也有可能没理解好。能教下我怎么处理吗?或者说明下。

【业务影响】无法同步数据
【是否存算分离】是
【StarRocks版本】例如:3.2.7
【集群规模】例如:1fe+1cn
【机器信息】16C32GB
【联系方式】bleibtreu@qq.com
【附件】
2024-06-05 09:57:14,261 ERROR com.starrocks.data.load.stream.v2.TransactionTableRegion [] - Failed to flush data for db: app_db, table: support_request after 0 times retry, the last exception is
java.lang.RuntimeException: com.starrocks.streamload.shade.org.apache.http.conn.HttpHostConnectException: Connect to 127.0.0.1:8040 [/127.0.0.1] failed: Connection refused (Connection refused)
at com.starrocks.data.load.stream.TransactionStreamLoader.doBegin(TransactionStreamLoader.java:157) ~[blob_p-8f8fa2d3b175c63d0370d62379eb8222381dbb63-fbb5b9726d94d34945536367acdb17d2:3.0.0]
at com.starrocks.data.load.stream.TransactionStreamLoader.begin(TransactionStreamLoader.java:99) ~[blob_p-8f8fa2d3b175c63d0370d62379eb8222381dbb63-fbb5b9726d94d34945536367acdb17d2:3.0.0]
at com.starrocks.data.load.stream.DefaultStreamLoader.send(DefaultStreamLoader.java:169) ~[blob_p-8f8fa2d3b175c63d0370d62379eb8222381dbb63-fbb5b9726d94d34945536367acdb17d2:3.0.0]
at com.starrocks.data.load.stream.v2.TransactionTableRegion.streamLoad(TransactionTableRegion.java:331) ~[blob_p-8f8fa2d3b175c63d0370d62379eb8222381dbb63-fbb5b9726d94d34945536367acdb17d2:3.0.0]
at com.starrocks.data.load.stream.v2.TransactionTableRegion.flush(TransactionTableRegion.java:228) ~[blob_p-8f8fa2d3b175c63d0370d62379eb8222381dbb63-fbb5b9726d94d34945536367acdb17d2:3.0.0]
at com.starrocks.data.load.stream.v2.StreamLoadManagerV2.lambda$init$0(StreamLoadManagerV2.java:220) ~[blob_p-8f8fa2d3b175c63d0370d62379eb8222381dbb63-fbb5b9726d94d34945536367acdb17d2:3.0.0]

有大佬抬一手吗? :pleading_face:

sr用什么部署的? allin1 docker image?

docker allin1试了,docker的存算分离版也用过

我觉得是执行请求发到FE节点,然后FE重定向的地址在其他容器里面访问打不了的原因,但是我不知道怎么修改这个重定向地址的host

allin1版本, 将flink中配置的load url 8030端口改成8080端口.

我尝试一下,我以为哪里是填其他端口,顺便能问一下这个load-url是干什么的吗?

教程上给的是对的啊.

问题报错的是连不上8040

改成8080 是正确的,load url 的作用是什么能告诉我吗?文档里面没找到解释

不好意思,是我的问题,非常感谢您的帮助!

你好,如果是k8s搭建的Starrock,这个地址如何写呢,现在本地flink调试k8s的Starrock ,错误和这个差不多,但k8s好像没有8080端口