Re: How to perform something on Checkpointing and Savepointing

Hi, I think maybe you could try to create a Function that implements WithMasterCheckpointHook. These hooks will be called by the checkpoint coordinator when triggering / restoring a checkpoint. You could see more details from [1]. [1] https://github.com/apache/flink/blob/master/flink-streaming-java

Re: How to perform something on Checkpointing and Savepointing

Tried these as well but they need to be called with some MapFunction or something else, we cannot just apply this Listener to the ExecutionEnvironment itself? Thanks and Regards , Surendra Lalwani On Mon, Sep 12, 2022 at 8:42 PM Ben Edwards wrote: > CheckpointedFunction / CheckpointListener. >

Re: How to perform something on Checkpointing and Savepointing

CheckpointedFunction / CheckpointListener. Best, Ben On Mon, Sep 12, 2022 at 4:01 PM Surendra Lalwani via user < user@flink.apache.org> wrote: > Hi Team, > > I want to perform some customized operations on checkpointing and > savepointing. For example, I want to create an additional file every