爲什麼創建flink檢查點差異如此之大

我能以某種方式獲得更多詳細信息創建flink檢查點時發生了什麼？創建檢查點弗林克的時間相差10倍。也就是說至少是我的jobmanager日誌告訴我：爲什麼創建flink檢查點差異如此之大

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分鐘）有關嗎？
除了頻率（和位置）之外，是否有任何方式影響檢查點創建？

來源

2017-02-14 TobiSH

Apache Flink 1.2在Web UI中提供非常詳細的檢查點統計信息。

檢查出引入了一些截圖的功能拉入請求：https://github.com/apache/flink/pull/3042

的UI將幫助您瞭解正在添加的時間是在哪裏。

這些文檔pagees可能是值得一讀：

來源

2017-02-14 09:34:33

感謝@rmetzger - 感謝信息。「調試和調整檢查點和大國」鏈接給了我正確的提示。 – TobiSH

爲什麼創建flink檢查點差異如此之大

回答

相關問題