当前位置:   article > 正文

Flink checkpointing 耗时很长_flink的checkpoint越来越久

flink的checkpoint越来越久

官方有提供checkpointing debug建议。

https://ci.apache.org/projects/flink/flink-docs-release-1.4/ops/state/large_state_tuning.html

现在遇到过的情况列举如下:




通过成功的checkpointing历史记录,查看start delay时间,推断出现在系统有背压。



第一次checkpointing就耗时很长,最终超时。

是有特殊的脏数据导致代码逻辑出bug,一直在while循环。 barrier 流不下去,导致一个task一直不能checkpoint成功。

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/秋刀鱼在做梦/article/detail/870878
推荐阅读
相关标签
  

闽ICP备14008679号