Flink同步MySQL至StarRocks报错求助：事务加载响应无Status字段

报错原因分析 #

报错提示事务开始请求的响应中找不到Status字段，尽管StarRocks 3.1.2本身支持事务加载，但结合你的配置和环境，问题大概率出在Flink-StarRocks连接器版本兼容性、配置冲突或者FE服务响应异常上：

• 你使用的flink-connector-starrocks-1.2.9_flink-1.16.jar与StarRocks 3.1.2版本适配性不足，导致连接器发起的事务请求格式与FE期望不匹配；
• 虽然配置了sink.properties.transaction.enabled = 'false'，但主键表（PRIMARY KEY）场景下连接器可能仍默认触发事务加载逻辑，引发配置冲突；
• FE服务未正常响应事务请求（报错中response为空），可能存在网络连通性问题或FE配置异常。

具体解决步骤 #

1. 升级Flink-StarRocks连接器版本 #

StarRocks 3.1.2属于较新版本，建议使用适配性更好的连接器版本，比如flink-connector-starrocks-1.3.6_flink-1.16.jar（该版本对StarRocks 3.x支持更完善）。替换依赖包后重新提交任务。

2. 调整Sink配置，明确禁用事务加载 #

在StarRocks Sink表的WITH参数中添加或修改以下配置，强制使用非事务的Stream Load模式：

CREATE TABLE IF NOT EXISTS cvm_price_factor_sink (
    Id BIGINT,
    Region STRING,
    SelfVersionNo BIGINT,
    NextVersionNo BIGINT,
    ChargeDetailType INT,
    Multi DECIMAL,
    Div DECIMAL,
    PRIMARY KEY (Id, Region) NOT ENFORCED
) WITH (
    'connector' = 'starrocks',
    'sink.max-retries' = '10',
    'sink.properties.strip_outer_array' = 'true',
    'sink.properties.format' = 'json',
    'sink.buffer-flush.interval-ms' = '5000',
    -- 新增或修改以下配置
    'sink.type' = 'stream-load',
    'sink.properties.transaction.enabled' = 'false',
    'jdbc-url' = 'jdbc:mysql://xxx:9030',
    'username' = 'root',
    'password' = 'xxx',
    'load-url' = 'xxx:8030',
    'database-name' = 'dev_int1_brp_oss',
    'table-name' = 'cvm_price_factor');

3. 检查FE服务与网络连通性 #

• 确认Flink集群能正常访问StarRocks FE的8030端口（可通过telnet xxx 8030或curl http://xxx:8030/api/dev_int1_brp_oss/cvm_price_factor/_stream_load测试）；
• 查看StarRocks FE的日志（fe/log/fe.log），检查是否有事务请求相关的错误日志，确认FE服务运行正常。

4. 确认StarRocks表模型兼容性 #

如果目标表是Primary Key模型，确保连接器配置与表模型匹配：

• 若不需要强一致性，可将表模型改为Duplicate Key（需重建表），此时连接器会使用普通Stream Load，避免事务逻辑；
• 若必须保留Primary Key模型，确保连接器版本支持该模型的事务加载，同时检查FE的enable_transactional_load配置是否开启（默认开启）。

内容的提问来源于stack exchange，提问作者turkey