【详述】搭建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]