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

在使用 Flink CDC 同步时,如何解决这个问题呢?

在使用 Flink CDC 同步 MySQL 数据到 Doris 的 unique key 表时,我能够同步更新操作,但删除操作却没有被同步。我不确定是不是我的代码配置有问题。以下是我的 source 端和 sink 端的配置。我使用的是版本2.0.1,目前在 unique key 和 duplicate 模型的表中都无法同步删除操作。如何解决这个问题呢?
c4a5cc52c97c33ea9cfa99a4279bf67f.pnge1b609345b01a8676581fa223af6079f.png

展开
收起
小小鹿鹿鹿 2024-03-19 23:07:13 45 0
1 条回答
写回答
取消 提交回答
  • doris 1.2.2 有 delete 不生效的问题。不知道是不是你这个版本。a17ed8ae170c6f1ac2ebec030b01a71f.png此回答来自钉群Flink CDC 社区。

    2024-03-20 12:22:58
    赞同 展开评论 打赏

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

相关产品

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

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

    相关镜像