Hi Adam,
you could have a local field in your operator which you initialize with
true on creation. Then in the map or process function you could check this
field and if true output all buffered state. At last you only need to set
this field to false so that any subsequent call to the map/process
Hi,
I'm new to Flink - but after reading the documentation -
What would be the best approach to stream data from a restored state
following a job restart ?
Say I have a MapState that gets populated during streaming with various
computed results within a stateful operator.
Upon job restart or on
