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/src/main/java/org/apache/flink/streaming/api/checkpoint/WithMasterCheckpointHook.java
On Mon, Sep 12, 2022 at 11:20 PM Surendra Lalwani via user < user@flink.apache.org> wrote: > 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 <b...@hypervolt.co.uk> wrote: > >> 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 time >>> checkpointing and savepointing gets triggered. Do we have anything as such? >>> Any listeners or anything else? >>> >>> Thanks and Regards , >>> Surendra Lalwani >>> >>> >>> ------------------------------ >>> IMPORTANT NOTICE: This e-mail, including any attachments, may contain >>> confidential information and is intended only for the addressee(s) named >>> above. If you are not the intended recipient(s), you should not >>> disseminate, distribute, or copy this e-mail. Please notify the sender by >>> reply e-mail immediately if you have received this e-mail in error and >>> permanently delete all copies of the original message from your system. >>> E-mail transmission cannot be guaranteed to be secure as it could be >>> intercepted, corrupted, lost, destroyed, arrive late or incomplete, or >>> contain viruses. Company accepts no liability for any damage or loss of >>> confidential information caused by this email or due to any virus >>> transmitted by this email or otherwise. >> >> > > ------------------------------ > IMPORTANT NOTICE: This e-mail, including any attachments, may contain > confidential information and is intended only for the addressee(s) named > above. If you are not the intended recipient(s), you should not > disseminate, distribute, or copy this e-mail. Please notify the sender by > reply e-mail immediately if you have received this e-mail in error and > permanently delete all copies of the original message from your system. > E-mail transmission cannot be guaranteed to be secure as it could be > intercepted, corrupted, lost, destroyed, arrive late or incomplete, or > contain viruses. Company accepts no liability for any damage or loss of > confidential information caused by this email or due to any virus > transmitted by this email or otherwise. -- Best, Hangxiang.
