Flink Checkpoint Timeout

[Mahantesh Patil]

Hello Team,

What happens after checkpoint timeout?

Does Flink reprocess data from the previous checkpoint for all tasks?

I have one compute intensive operator with parallelism of 20 and only one
of the parallel tasks seems to get stuck because of data skew. On
checkpoint timeout , will data be reprocessed or continue processing new
data? If not, will increasing checkpoint timeout help.

Checkpoint Configuration:

CheckpointingMode.EXACTLY_ONCE;

CheckPointTimeOut 10 min;

MinPauseBetweenCheckpoints 30 sec;

CheckPointingInterval 30 sec;


Thanks,
Mahantesh