技术场景:Flink-connector-doris
Flink:1.14.5
doris : 1.2.3-rc02
场景:
场景A : flink sql消费kafka, look up [jdbc] join doris维表. 写入【unique】的 doris结果表。发现一个新增4个变更,只有新增的写入了,变更的没有写入
场景B:我们还存在一个日志表【duplicate】模式的doris表,kafka → fllink sql → doris duplicate . 这个是正常写入的。
场景C:我把场景A的任务复制一份,重新处理一遍,写入不同的结果表,业务正常。