tongchenkeji 发表于：2022-9-8 11:19:530次点击 已关注取消关注 关注 私信 flink对于自增ID为主键的MySQL表怎么处理一致性的[阿里云实时计算 Flink版] 暂停朗读为您朗读 flink对于自增ID为主键的MySQL表怎么处理一致性的 「点点赞赏，手留余香」 赞赏 还没有人赞赏，快来当第一个赞赏的人吧！ 海报 实时计算Flink版# MySQL1179# 云数据库 RDS MySQL 版1517# 关系型数据库2577# 实时计算 Flink版3179# 流计算2236
V主宰AM 2023-11-27 18:12:59 1 Flink映射表主键设置为MySQL的唯一索引（不是MySQL表主键），同时不声明MySQL主键字段，利用on duplicate key特性更新MySQL
认真学习的heartAM 2023-11-27 18:12:59 4 Flink可以通过使用“查询语句”或“查询参数”来处理MySQL表中的自增ID主键。 查询语句可以指定查询条件，以确保只查询出满足条件的记录，而查询参数可以指定查询的起始ID，以确保每次查询都只查询出新增的记录。这样可以确保Flink处理MySQL表中的自增ID主键时保持一致性。
Flink映射表主键设置为MySQL的唯一索引（不是MySQL表主键），同时不声明MySQL主键字段，利用on duplicate key特性更新MySQL
楼主你好，flink对于自增ID为主键的MySQL表处理一致性是通过查询参数结合查询语句结合使用的，而且自增是需要连续性的
只要保证MySQL表的自增id区间一致就好了，自增一定是连续的。
Flink可以通过使用“查询语句”或“查询参数”来处理MySQL表中的自增ID主键。
查询语句可以指定查询条件，以确保只查询出满足条件的记录，而查询参数可以指定查询的起始ID，以确保每次查询都只查询出新增的记录。这样可以确保Flink处理MySQL表中的自增ID主键时保持一致性。