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
can do your
computations/joining of two events on same key from two streams. In this way,
it can handle the largest delay.
From: Mazen Ezzeddine
Sent: 16 September 2020 13:37
To: user@flink.apache.org
Subject: Connecting two streams and order of their processing
Hello all,
If an event is available now to Flink keyedcoprocess operator, and if
another event will be available 1 minute later to that operator (same key),
as a result of connecting the two streams, Flink does not provide any
guarantee that the event available now will be processed (processElemen
