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

实时计算 Flink版checkpoint失败,为什么?

实时计算 Flink版checkpoint失败,为什么?整个yarn日志没有特别明显的报错日志,只能定位到checkpoint在完成前已过期了,设置的ck时间是5分钟一次。 523ac0cca66f22651b7617288d00c437.png

展开
收起
游客uu65yiq7myioi 2023-02-14 14:15:02 262 0
1 条回答
写回答
取消 提交回答
  • 超时了,你触发checkpoint 是 00:10 00:35告诉你超时了,如果job没有明确原因,你可以看看task的,通信超时什么的都有可能,你job 最开始报错的是checkpoint 时间点 是 00:10 你再这个时间点开始看看,应该这个checkpoint时间 task 有问题导致超时失败——该回答整理自钉群“【③群】Apache Flink China社区”

    2023-02-14 16:35:11
    赞同 展开评论 打赏

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

相关产品

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

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