【详述】flink任务使用flink-connector-starrocks-1.2.7读取数据,fe节点宕机后,任务失败
【背景】fe节点 26.129.12.209宕机
【是否存算分离】否
【StarRocks版本】2.5.13
【connector版本】flink-connector 1.2.7
【集群规模】例如:3fe(1leader 2 follower)+3be(fe与be独立部署)
- 导入报错
Caused by: java.lang.RuntimeException: failed to get queryInfo:connect to 26.129.12.209:8030 [/26.129.12.209] failed: connection timed out (connection
timed out)
at com.starrocks.connector.flink.table.source.StarRocksSourceCommonFunc.getQueryInfo(StarRocksSourceCommonFunc.java: 208)
flink读取starrocks数据任务scan-url配置如下:scan-url:26.129.12.208:8030,26.129.12.209:8030,26.129.12.210:8030
问题:配置了三个地址为何没有避免单点故障