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

flink cdc在insert的时候为什么会有do update?

flink cdc在insert的时候为什么会有do update?3e7e869fe6c51b5cc775264f4f6b8fd5.png能取消这个do update吗?到分布式数据库 分布式数据库主键不能更新,这个日志里面insert带 do update 就触发了分布式数据库不能更新主键,flink 可以实现到分布式数据库吗?

展开
收起
小小鹿鹿鹿 2024-05-01 08:56:12 15 0
1 条回答
写回答
取消 提交回答
  • 你这个最好把sql到目标库里执行一下看看是什么问题,而不是去取消幂等写入。9856005a5ee94b12e468c922df026b9c.png此回答来自钉群Flink CDC 社区 。

    2024-05-01 13:03:28
    赞同 1 展开评论 打赏

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

相关电子书

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