Re: flink 1.11.1 使用flinksql，jdbc ，后台数据库设置主键的情况下，upsert不生效

Hi, 你确定是在Flink SQL 里使用 upsert 语法？ 我理解是不支持的 另外你flink里声明connector DDL 中的主键应该和你在Mysql表的主键一致。 祝好 Leonard > 在 2020年11月17日，09:12，鱼子酱 <384939...@qq.com> 写道： > > upsert

flink 1.11.1 使用flinksql，jdbc ，后台数据库设置主键的情况下，upsert不生效

请问使用mysql数据库时，使用flinksql，已经设置主键的情况下，相同主键的记录没有更新，而是越来越多， 是目前不支持还是我使用的方法不对呢？ 版本：flink 1.11.1 关键的2个sql如下 create table open_and_close_terminal_minute_1 ( request_date varchar ,terminal_no varchar ,logon_time varchar ,logout_time varchar ,insert_time varchar ,P