Hi,
你确定是在Flink SQL 里使用 upsert 语法? 我理解是不支持的

另外你flink里声明connector DDL 中的主键应该和你在Mysql表的主键一致。

祝好
Leonard

> 在 2020年11月17日,09:12,鱼子酱 <384939...@qq.com> 写道:
> 
> upsert

回复