为什么flink检查点的创建差异如此之大

Question

在创建flink检查点时,我能否以某种方式获取更多详细信息？创建flink检查点的时间因子10而异.这至少是我的jobmanager logfile告诉我的:

2017-02-14 09:03:43,234 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator     - Triggering checkpoint 161 @ 1487059423232
2017-02-14 09:08:17,447 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator     - Completed checkpoint 161 (in 271425 ms).
2017-02-14 09:08:43,233 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator     - Triggering checkpoint 162 @ 1487059723233
2017-02-14 09:09:46,684 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator     - Completed checkpoint 162 (in 61951 ms).

检查点161只需要一分钟即可创建,而下一个检查点162需要4.5分钟(它持续8分钟而不是回到1.5分钟).

• 这可能与我使用的一些TumblingWindows有关(窗口持续时间为3分钟)？
• 有没有办法影响频率(和位置)旁边的检查点创建？

Answer 1

Apache Flink 1.2在Web UI中提供非常详细的检查点统计信息.

查看为某些屏幕截图引入该功能的pull请求:https://github.com/apache/flink/pull/3042

用户界面将帮助您了解添加时间的位置.

这些文档页面可能值得一读:

• 监控检查点
• 调试和调整检查点和大状态