【详述】starrocks连续两次sink操作，偶现第二次sink的数据没有更新
【背景】无
【业务影响】导致业务宽表数据不能正常更新
【是否存算分离】否
【StarRocks版本】2.5.21
【集群规模】3fe，3be
【机器信息】32c/128g/万兆网卡
【表模型】主键模型
【导入或者导出方式】Flink-Connector-StarRocks
【联系方式】StarRocks社区群14-andy，谢谢
【附件】
没有异常日志，程序也没有报错，底层调用的是
dataStream.addSink(StarRocksSink.sink(
(StarRocksSinkOptions.builder()
.withProperty(“jdbc-url”, jdbcUrl)
.withProperty(“load-url”, loadUrl)
.withProperty(“username”, userName)
.withProperty(“password”, passWord)
.withProperty(“database-name”, db)
.withProperty(“table-name”, table)
.withProperty(“sink.semantic”, “exactly-once”)
.withProperty(“sink.properties.format”, “json”)
.withProperty(“sink.buffer-flush.max-rows”, “64000”)
.withProperty(“sink.buffer-flush.max-bytes”, “104371840”)
.withProperty(“sink.buffer-flush.interval-ms”, “2000”)
.withProperty(“sink.properties.partial_update”, “true”)
.withProperty(“sink.properties.columns”, updateFileds)
.withProperty(“sink.properties.strip_outer_array”, “true”)
.withProperty(“sink.properties.ignore_json_size”, “true”)
.withProperty(“sink.properties.column_separator”, “\x01”)
.withProperty(“sink.properties.row_delimiter”, “\x02”)
.withProperty(“sink.parallelism”, “1”)
.build())))
.setParallelism(1).name(taskName);
并发为1 ，连续两次sink 第二次没有更新指的是什么，能找到第二次sink时导入任务的label 么。
提供下 当时完整的 flink taskmanager 的日志 以及 leader fe.log 的日志
问题已找到，不是数据sink没有更新，而是由于程序内部并发问题所导致。谢谢