Flink CDC中加了一张4千万数据的表,从savepoint恢复的,然后就开始各种重启什么原因?

Flink CDC中加了一张4千万数据的表,从savepoint恢复的,然后就开始各种重启,flink 1.14.5 mysql cdc 2.4.1,什么原因?
c79ca6f7a8c5b386a9a0296d270f6a1d.png

展开
收起
小易01 2023-08-16 00:59:06 77 分享 版权
1 条回答
写回答
取消 提交回答
  • 意中人就是我呀!

    看起来像你这个ckp干爆了,加并行度,你这张表太大了。此答案整理至钉群“Flink CDC 社区“。

    2023-08-16 08:58:41
    赞同 展开评论

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

还有其他疑问?
咨询AI助理