I have a flink job with a big enough state that makes checkpointing long ( ~ 70 
seconds).
I have configured the checkpoint timeout to 180 seconds 
(setCheckpointTimeout(180000))
But as you can see from the following logs, timeout seems to be ~60 seconds.

Is there another timeout configuration I need to set?

2018-08-29 11:41:03,883 INFO  
org.apache.flink.runtime.checkpoint.CheckpointCoordinator     - Triggering 
checkpoint 61 @ 1535542863734 for job aae565f4f6efba50d5252fc1afd7c255.
2018-08-29 11:42:03,883 INFO  
org.apache.flink.runtime.checkpoint.CheckpointCoordinator     - Checkpoint 61 
of job aae565f4f6efba50d5252fc1afd7c255 expired before completing.
2018-08-29 11:42:13,955 WARN  
org.apache.flink.runtime.checkpoint.CheckpointCoordinator     - Received late 
message for now expired checkpoint attempt 61 from 
f022ce60f0f5da2a34290574305813d8 of job aae565f4f6efba50d5252fc1afd7c255.


Jo

Reply via email to