flink-connector-starrocks

[U_1665487912221_3689]

环境信息
starrocks 版本：StarRocks-2.3.0-rc03
flink 版本：1.14.2 scale 2.11
flink-connector-starrocks 1.2.3_flink-1.14_2.11

问题：
连接器 jdbcurl 配置为多个 FE 节点时，会出现读取不到 tablet 的报错。

现象：

1. 13:44:00.368992 83296 tablet_updates.cpp:1516] remove_expired_versions tablet:2250223 #version:3 [204 206@2 206] #pending:0 time:1667193240 max_expire_version:203 deletes: #version:1 #rowset:0 #delvecrange:1
2. 然后 flink 任务在 13:44:02 的时候，想要拉取这个 tablet:2250223 #version:3 [204 206@2 206] 找不到了

BE 日志

flink 任务异常日志

JDBC url 改用 leader 节点一个，则问题不复现。

[U_1665487912221_3689]

实际测试证明， JDBC url 直接用 FE 的 leader 节点，同样存在问题。

该问题存在偶现的情况

[U_1665487912221_3689]

tablet 对应 的表结构

CREATE TABLE scd_object_store (

uuid varchar(1000) NOT NULL COMMENT “”,

subject_id varchar(1000) NOT NULL COMMENT “”,

field_name varchar(1000) NOT NULL COMMENT “”,

field_value varchar(1000) NULL COMMENT “”,

valid_date varchar(1000) NOT NULL COMMENT “”,

invalid_date varchar(1000) NOT NULL COMMENT “”

) ENGINE=OLAP

PRIMARY KEY(uuid)

COMMENT “OLAP”

DISTRIBUTED BY HASH(uuid) BUCKETS 4

PROPERTIES (

“replication_num” = “3”,

“in_memory” = “false”,

“storage_format” = “DEFAULT”,

“enable_persistent_index” = “false”

);

[xixiuxiu]

遇到同样的问题
jdbc连接多节点时读取异常
希望大佬解答一下