Re: Connecting two streams and order of their processing

2020-09-16 Thread David Anderson
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

Re: Connecting two streams and order of their processing

2020-09-16 Thread Jaswin Shah
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