Sorry for the late response... In which Flink version are
I am wondering if this is somewhat related to that specific
DFS filesystem mounted on Linux with CIFS
- For the "completedCheckpoint<SomeID>",
the cleanup should happen in the
"ZooKeeperCompletedCheckpointStore" when dropping a
- For the "state.backend.fs.checkpointdir/JobId/check-<INTEGER>"
directory, it should (in Flink 1.3 and 1.4) be the
FileStateHandle that deletes the parent directory when
empty, meaning the last state chunk to be deleted deletes
the parent directory. In Flink 1.5, it is the disposal
call of the CheckpointStorageLocation.