Re: Guarantee of event-time order in FlinkKafkaConsumer

2019-10-25 Thread Fabian Hueske
odic watermarks every 1s. I > use FlinkKafkaConsumer with AscendingTimestampExtractor. > The code (and the same question) is here: > https://stackoverflow.com/questions/58539379/guarantee-of-event-time-order-in-flinkkafkaconsumer > > I realized, that for unordered events, that came in t

Guarantee of event-time order in FlinkKafkaConsumer

2019-10-24 Thread Wojciech Indyk
/guarantee-of-event-time-order-in-flinkkafkaconsumer I realized, that for unordered events, that came in the same ms or a few ms later, the order is not corrected by Flink. What I found in the docs: "the watermark triggers computation of all windows where the maximum timestamp (which is end-time