I'm not sure if this would work, but you could try implementing the
CheckpointedFunction interface and getting access to state that way.
On 14/02/2022 16:25, Clayton Wohl wrote:
Is there any way to save a custom application-global cache into Flink
state so that it is used with checkpoints + savepoints? This cache is
used by a RichAsyncFunction that queries an external database, and
RichAsyncFunction doesn't support the Flink state functionality directly.
I asked this last week but got no answers. I wanted to ask a second
time. Thank you :)
