ynchronization in the performance test)? Efficient stateful stream
> processing is one of the key features of Flink, and you are essentially
> trying to override a specific piece of it with custom logic.
>
> Best regards,
> Nico
>
> On Wed, Oct 6, 2021 at 5:50 PM Marc LEGER wr
; Best regards,
> Nico
>
> [1]
> https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedFunction.java#L74-L110
>
> On Tue, Oct 5, 2021 at 3:28 PM Marc LEGER wrote:
>
>> Hello,
>>
>&
Hello,
Is there any method available in a RichFunction to be called by Flink with
a keyed context each time a checkpoint is triggered please ?
It seems that the CheckpointedFunction interface provides such a feature
(snapshotState method) but only in case of operator state and it is called
in a
oo often and would not make much sense in production environment.
>>>
>>> Best
>>> Yun Tang
>>> --
>>> *From:* Till Rohrmann
>>> *Sent:* Thursday, April 9, 2020 17:41
>>> *To:* Marc LEGER
>>>
untime/checkpoint/ZooKeeperCompletedCheckpointStore.java#L234
>
> Best
> Yun Tang
>
> --
> *From:* Marc LEGER
> *Sent:* Wednesday, April 8, 2020 16:50
> *To:* user@flink.apache.org
> *Subject:* Possible memory leak in JobManager (Flink 1.10.
