Re: Tumbling window with timestamp out-of-range events

Please ignore this message. The issue was that a different timestamp extractor was used when the kafka source was setup. That caused the issue. On Tue, Jun 9, 2020 at 2:58 PM Yu Yang wrote: > Hi, > > > We implement a flink application that uses TumblingWindow, and uses even > time as time charac

Tumbling window with timestamp out-of-range events

Hi, We implement a flink application that uses TumblingWindow, and uses even time as time characteristics. In the TumblingWindow's process function, we has the implementation below that checks whether the event's timestamp is in the tumbling window's timestamp range. We expected that all events