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

Flink CDC1.13版本的checkpoint针对于大状态的设置调优能给下参考吗?

Flink CDC1.13版本的checkpoint针对于大状态的设置调优能给下参考吗?现在做了13个人员子集的聚合,然后关联到人员主体上老是checkpoint失败,过段时间task manger不可用以后导致整个源头重新摄取了,而且数据量比较大,这样导致永远初始不完数据?

展开
收起
真的很搞笑 2023-12-05 20:43:30 55 0
1 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    Flink CDC 1.13版本的checkpoint针对大状态的设置调优,主要需要考虑以下两个方面:首先,应用程序需要能够可靠地创建checkpoints;其次,在应用故障后,需要有足够的资源追赶数据输入流。

    对于大状态的作业,如果发现Checkpoint时间过长,可以考虑优化Checkpoint的时间间隔。具体来说,可以通过调整Checkpoint之间的最小间隔参数,让Checkpoint之间根据执行速度进行调整。也就是说,前面的Checkpoint没有完全结束,后面的Checkpoint就不会开始,这样可以有效地提高作业的运行效率。

    此外,还可以通过观察每个Checkpoint的启动时间来检测每个Checkpoint之前和之后是否存在空闲时间间隔,以此来进一步微调Flink Checkpoint操作。

    总的来说,Flink提供了丰富的运行参数,用户可以根据自己的作业特点进行个性化的调优。例如,可以限制Checkpoint的最小制作间隔来避免不合理的高频Checkpoint制作影响集群上的其他作业。

    2023-12-06 14:35:53
    赞同 展开评论 打赏

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

相关产品

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

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