Hi, I had a question regarding CheckpointListener. Is it possible to register some function for onCheckpointComplete I'm looking if there's something like:

env.addCheckpointListener(checkPtComplete())

Or any alternate way I can listen to checkpoints and do some logic ?

In principle, checkpointing is an internal mechanism. What’s your use case?

I want to perform some operation like saving state in a database after checkpointing. Specifically, I'm using some custom path filter for readFiles() method, and I want to persist some state related to it on checkpoint. I do see that there is checkpoint listener interface in flink that can be implemented, but not sure how I can add it to the execution environment