Roman Khachatryan created FLINK-24938: -----------------------------------------
Summary: Checkpoint cleaner is closed before checkpoints are discarded Key: FLINK-24938 URL: https://issues.apache.org/jira/browse/FLINK-24938 Project: Flink Issue Type: Bug Components: Runtime / Checkpointing Affects Versions: 1.14.0, 1.15.0 Reporter: Roman Khachatryan Fix For: 1.15.0, 1.14.1 When CompletedCheckpointStore shuts down it tries to discard some checkpoints using CheckpointCleaner. The latter is closed asynchronously since FLINK-23647 and before the Store. Visible as warning when running ResumeCheckpointManuallyITCase.testExternalizedIncrementalRocksDBCheckpointsZookeeper: {code} 2021-11-17 10:47:10,599 Fail to remove checkpoint during shutdown. [DefaultCompletedCheckpointStore flink-akka.actor.default-dispatcher-5] java.lang.IllegalStateException: CheckpointsCleaner has already been closed at org.apache.flink.util.Preconditions.checkState(Preconditions.java:193) ~[classes/:?] at org.apache.flink.runtime.checkpoint.CheckpointsCleaner.incrementNumberOfCheckpointsToClean(CheckpointsCleaner.java:105) ~[classes/:?] at org.apache.flink.runtime.checkpoint.CheckpointsCleaner.cleanup(CheckpointsCleaner.java:87) ~[classes/:?] at org.apache.flink.runtime.checkpoint.CheckpointsCleaner.cleanCheckpoint(CheckpointsCleaner.java:62) ~[classes/:?] at org.apache.flink.runtime.checkpoint.DefaultCompletedCheckpointStore.tryRemoveCompletedCheckpoint(DefaultCompletedCheckpointStore.java:2 at org.apache.flink.runtime.checkpoint.DefaultCompletedCheckpointStore.shutdown(DefaultCompletedCheckpointStore.java:172) ~[classes/:?] at org.apache.flink.runtime.scheduler.SchedulerBase.shutDownCheckpointServices(SchedulerBase.java:222) ~[classes/:?] {code} But the test still passes. cc: [~pnowojski] -- This message was sent by Atlassian Jira (v8.20.1#820001)