Flink写入starrcosk问题

Flink使用flink-connector-starrocks写入starrocks,flink计算的结果是一张用户表,表里面有用户的各种标签,starrocks使用主键模型,按照用户标识去重,如果间隔一秒前后来了两条数据主键相同,会按照顺序更新,保留最新的一条吗,sink.buffer-flush.interval-ms设置为10秒

https://docs.starrocks.io/zh-cn/latest/loading/Load_to_Primary_Key_tables#条件更新可以增加条件列保证有序,sink中增加属性“sink.properties.merge_condition: col1”,可以让主键模型中数据按照主键去重的同时,根据col1 来判断是否保留

好的,已经测试可以使用,多谢