Hi,

reading through the documentation regarding waterrmarks, it is not clear to me 
if watermarks are also used by map/flatmpat operators or just by window 
operators.

My application reads from a kafka topic (with multiple partitions) and extracts 
assigns timestamp on each tuple based on some fields of the kafka records. A 
following keyBy operator creates partitions and sends the tuples to the 
corresponding downstream map/flatmap operator. I have set the 
timecharacteristic to EventTime.

However, it seems that the flatmap operator *does not* guaranteed that it will 
process elements in an deterministic time order.
Is this correct?

Antonis



Reply via email to