I am experiencing extremely slow checkpoints after upgrading flink version from 1.13.1 to 1.14.3. The checkpointing is slow because of the sink/source.
Example
This source is a kafka topic that have some messages inside and still, it might take up to minutes to be checkpointed.
I am using incremental checkpoints, unaligned checkpoints are not enabled. Configurations are the default ones, and this source was checkpointed for milliseconds with flink 1.13.1 and now it times out(the timeout is 3 minutes) for every second chechpoint.
FlinkKafkaConsumer/Producer are used which are deprecated.