嗯，应该是没问题的，我理解错了，谢谢指正。
发件人: 史 正超
发送时间: 2020年11月5日 19:30
收件人: user-zh@flink.apache.org
主题: 回复: Flink1.11.0 sql
org.apache.flink.connector.jdbc.dialect.MySQLDialect发现疑似bug
应该是没有问题的，
首先你在flink sql中指定的primary key 应该要与mysql中的唯一索引或者主键对应。
其次那个方法里组装出来的语句 类似下面的语句:
INSERT
应该是没有问题的，
首先你在flink sql中指定的primary key 应该要与mysql中的唯一索引或者主键对应。
其次那个方法里组装出来的语句 类似下面的语句:
INSERT INTO `tablename`(`key1`, `key2`, `f1`, `f2`) VALUES (?, ?, ?, ?) ON
DUPLICATE KEY UPDATE `key1`=VALUES(`key1`), `key2`=VALUES(`key2`),
`f1`=VALUES(`f1`), `f2`=VALUES(`f2`)
里面已经包含了定义的key,
