Thanks Guowei and Alexey, looking at the references you provided helped. I
managed to put together simple examples using both the streaming Table API as
well as using the CEP library, and I’m now able to process events in event time
order. I believe to me my interpretation of setting up watermar
Hi Oliver
I think Alexey is right that you could not assume that the record would be
output in the event time order.
And there is a small addition.I see your output and there are actually
multiple concurrencies (probably 11 subtasks). You also can't expect these
concurrencies to be ordered accordi
Hi Oliver,
I believe you also need to do sort, out of order ness watermark strategy only
“postpone” watermark for given expected maximum of out of orderness. Check
Ververica example -
https://github.com/ververica/flink-training-exercises/blob/master/src/main/java/com/ververica/flinktraining/exam
