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

对于Flink CDC,大家是如何解决这种问题的?

对于Flink CDC,大家是如何解决这种问题的? pgsql每个slot槽是对整个库监控,但是使用cdc sql对每张表进行同步时,每张表都需要声明一个单独的slot name,并且随着时间推移,slot会越来越大(我发现a表使用的slot,如果对b表写入大量数据,slot会变得很大,并且不会减小),最后导致任务oom。

展开
收起
665661 2023-01-15 19:46:01 198 0
1 条回答
写回答
取消 提交回答
  • GitHub https://github.com/co63oc/cloud

    https://zhuanlan.zhihu.com/p/449066277 记录cdc postgres slot报错 image.png

    2023-01-15 21:41:23
    赞同 展开评论 打赏

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

相关产品

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

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