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