flink任务使用flink-connector-starrocks-1.2.7读取数据,fe节点宕机后任务失败

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

问题:配置了三个地址为何没有避免单点故障

stream_load配置三个做不了高可用,可以搞个vip