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

Flink CDC版本2.4.1 导致后续没有数据流入 能帮忙看下吗?

Flink CDC版本2.4.1 scanNewlyAddedTableEnabled打开后 从savepoint启动后 扫描新增表报 The enumerator received invalid request meta group id 导致后续没有数据流入 能帮忙看下吗?image.png

展开
收起
真的很搞笑 2023-09-13 15:06:00 52 0
1 条回答
写回答
取消 提交回答
  • 会有,升级debizum版本,debeizum 2.0 版本的重构很多API都改过了,Flink CDC 依赖的是debezium 1.9.7, 差异还挺大的,此回答整理自钉群“Flink CDC 社区”

    2023-09-13 17:06:40
    赞同 展开评论 打赏

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

相关产品

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

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