BoundedOutOfOrdernessTimestampExtractor and allowedlateness

Posted by Yassine MARZOUGUI on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/BoundedOutOfOrdernessTimestampExtractor-and-allowedlateness-tp9583.html

Hi,

I'm a bit confused about how Flink deals with late elements after the introduction of allowedlateness to windows. What is the difference between using a BoundedOutOfOrdernessTimestampExtractor(Time.seconds(X)) and allowedlateness(Time.seconds(X))? What if one is used and the other is not? and what if a different lateness is used in each one? Could you please clarify it on basis of a simple example? Thank you.

Best,

Yassine