是的，目前是更新相同pk的记录，如果需要统计相同pk的记录， Flink表不声明PK就是append 写入，就会有写入多条记录，(DB里的表也不声明pk，不然insert会报错)。
祝好 > 在 2020年7月14日，18:21，小学生 <[email protected]> 写道： > > 嗯嗯，谢谢大佬的解答，还有一个问题就是sql自己的语法是支持增量式的比如score=score+1,现在flink1.11特性反应成数据库 upsert > SQL的方式，其实是全量的更新同Pk的记录吧，并达不到增量的情况吧。
