global state and single stream

Hi, I am pretty new to Flink and I'm trying to implement - which seems to me - a pretty basic pattern: Say I have a single stream of *Price *objects encapsulating a price value and a symbol (for example A to Z) they are emitted at a very random interval all day - could be 1 /day or once a

streaming restored state after restart

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