Re: FlinkSQL Upsert/Retraction 写入 MySQL 的问题

Hi, wanglei PLEASE use English when send mails to user(user@flink.apache.org) mail list. You should send to to user-zh(user...@flink.apache.org) mail list, and I’m pleasure to answer the question here. Best, Leonard Xu > 在 2020年4月27日，12:14，wangl...@geekplus.com.cn 写道： > > > > INSERT INTO mys

FlinkSQL Upsert/Retraction 写入 MySQL 的问题

INSERT INTO mysql_sink SELECT f1, count(*) FROM kafka_src GROUP BY f1 每从 kafka 过来一条新的记录，会生成两条记录 Tuple2, 旧的被删除，新的会添加上。 但这个 Sink 到底是用到了 UpsertStream 还是 RetractStream 呢，怎么判断是 UpsertStream 还是 RetractStream 呢？ 我看 https://github.com/apache/flink/tree/master/flink-connectors/flink-jdbc/src/main/ja