开发者社区> 问答> 正文

为什么flink1.11.2检查点失败?

我这面在使用flink1.11.2做实时特征的时候,状态大小大约在30g左右的时候任务就不能继续运行了,而查看异常日志发现大量的InterruptedException,请问这种情况是集群的问题还是flink的问题,而另一个3G状态的任务依然正常运行*来自志愿者整理的flink邮件归档

展开
收起
又出bug了-- 2021-12-02 11:44:01 451 0
1 条回答
写回答
取消 提交回答
  • 补充一下,状态后端选择的是rocksdb,检查点间隔为15分钟,超时时间为5分钟,感觉5分钟超时已经很大了,结果检查点线程还是会被中断,是需要继续调大超时时间吗*来自志愿者整理的FLINK邮件归档

    2021-12-02 14:25:45
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

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