The details of what can go wrong will vary depending on the precise
scenario, but no, Flink is unable to provide any such guarantee. Doing so
would require being able to control the scheduling of various threads
running on different machines, which isn't possible.
Of course, if event A becomes ava
With Keyed dual stream processing, you make sure that events for same key to
processElement 1 and 2 are received to same partition. However, when you
receive an event in processElement1, you should store that in flinks state so
that if an another event arrives on delay to processElement2, you ca