开发者社区大数据与机器学习实时计算 Flink 正文

flink对于自增ID为主键的MySQL表怎么处理一致性的

收起

游客6vdkhpqtie2h2 2022-09-08 11:19:53 997 发布于浙江版权

4 条回答

写回答

取消提交回答

V主宰

Flink映射表主键设置为MySQL的唯一索引（不是MySQL表主键），同时不声明MySQL主键字段，利用on duplicate key特性更新MySQL

2023-01-30 13:18:25 举报

赞同评论

评论
全部评论 (0)
登录后可评论
三掌柜666

十分耕耘，一定会有一分收获！

楼主你好，flink对于自增ID为主键的MySQL表处理一致性是通过查询参数结合查询语句结合使用的，而且自增是需要连续性的

2023-01-30 11:37:59 举报

赞同 1 评论

评论
全部评论 (0)
登录后可评论
wljslmz

公众号：网络技术联盟站，InfoQ签约作者，阿里云社区签约作者，华为云云享专家，BOSS直聘创作王者，腾讯课堂创作领航员，博客+论坛：https://www.wljslmz.cn，工程师导航：https://www.wljslmz.com

只要保证MySQL表的自增id区间一致就好了，自增一定是连续的。

2023-01-29 15:38:11 举报

赞同评论

评论
全部评论 (0)
登录后可评论
认真学习的heart

Flink可以通过使用“查询语句”或“查询参数”来处理MySQL表中的自增ID主键。

查询语句可以指定查询条件，以确保只查询出满足条件的记录，而查询参数可以指定查询的起始ID，以确保每次查询都只查询出新增的记录。这样可以确保Flink处理MySQL表中的自增ID主键时保持一致性。

2023-01-17 17:27:12 举报

赞同评论

评论
全部评论 (0)
登录后可评论

问答分类：

关系型数据库 MySQL 流计算实时计算 Flink版云数据库 RDS MySQL 版

问答标签：

实时计算 Flink版mysql flink云数据库 RDS MySQL 版云数据库 RDS MySQL 版id 云数据库 RDS MySQL 版自增云数据库 RDS MySQL 版flink

问答地址：

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问

收录在圈子:

阿里云实时计算Flink

199211

+ 订阅

实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。

Typecho 入门指南：个人博客网站保姆级攻略！

mysql注入-字符编码技巧

登顶TPC-C｜云原生数据库PolarDB技术揭秘：单机性能优化篇

【YashanDB知识库】hive初始化崖山报错YAS-04209

【YashanDB 知识库】使用 Reverse 索引的解决自增序列做索引，插入性能大幅提升