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
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.
>
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
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
-
