Hi Adam,
sorry for the late reply. Introducing a global state is something that
should be avoided as it introduces bottlenecks and/or concurrency/order
issues. Broadcasting the state between different subtasks will also bring a
loss in performance since each state change has to be shared with every
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 we
