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

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

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

展开
收起
游客6vdkhpqtie2h2 2022-09-08 11:19:53 980 0
4 条回答
写回答
取消 提交回答
  • Flink映射表主键设置为MySQL的唯一索引(不是MySQL表主键),同时不声明MySQL主键字段,利用on duplicate key特性更新MySQL

    2023-01-30 13:18:25
    赞同 展开评论 打赏
  • 十分耕耘,一定会有一分收获!

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

    2023-01-30 11:37:59
    赞同 1 展开评论 打赏
  • 公众号:网络技术联盟站,InfoQ签约作者,阿里云社区签约作者,华为云 云享专家,BOSS直聘 创作王者,腾讯课堂创作领航员,博客+论坛:https://www.wljslmz.cn,工程师导航:https://www.wljslmz.com

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

    2023-01-29 15:38:11
    赞同 展开评论 打赏
  • Flink可以通过使用“查询语句”或“查询参数”来处理MySQL表中的自增ID主键。

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

    2023-01-17 17:27:12
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载

    相关镜像