Flink 1.3.2 FileState Backend Currently have 1 Job Manager with 1 Task Manager
I believe this should happen automatically, however there are hundreds of checkpoint files building up in my data directory. I have tried numerous attempts to clean up the checkpoint data via setting fileStateSizeThreshold when instantiating FsStateBackend object for environment. I have also tried to set config option 'state.checkpoints.num-retained: 5' Is there something I am doing wrong or is this a potential bug in 1.3.2? Checkpoint Config : Option: Value Checkpointing Mode: Exactly Once Interval: 30s Timeout: 10m 0s Minimum Pause Between Checkpoints: 0ms Maximum Concurrent Checkpoints: 1 Persist Checkpoints Externally Disabled -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
