Flink 社区版 checkpoint 的频率问题

Mon, 23 Sep 2019 20:24:19 -0700 

各位大神好！
问题背景：
1.flink版本是社区版1.6，checkpoint采用的是RocksDBStateBackend
2.flink作业是5分钟窗口的统计，在设置checkpoint时interval间隔 如何设置，是否需要考虑窗口的时间？
3.目前我有一个flink作业的checkpoint大概情况如下，如果频繁checkpoint hdfs会产生大量操作日志，如果写入S3 
也会有大量请求。我的解决办法是降低checkpoint频次（增大间隔时间）。

End to End DurationState SizeBuffered During Alignment
Minimum1s35.4 MB0 B
Average4s647 MB4.51 MB
Maximum44s3.26 GB217 MB
我想请教下如何合理的设置checkpoint ？


谢谢！

回复