Hi!
The order of tuples in stream may vary, depending on certain operations.
When windows are computed on "processing time" (sometimes called "stream
time"), then the result of the windowing depends on the speed of the tuple
streams. There are multiple possible outcomes of the computation.
Upon r
Dear Sir:
I am a beginner of Flink and very interested in “Exactly-once” Recovery
Mechanism. I have a question about processing sequence problem of tuples. For
example, in Fig 1, process unit A runs JOIN, and the size of sliding window is
4. At the beginning, the state of sliding windows is show