Hi! I'm not sure whether I understand your question. The purpose of Event Time is to be able to process out-of-order events. Do you want to discard late elements? In the upcoming Flink 1.1.0 you can set the `allowedLateness` on a windowed stream. The default is 0, so late elements are discarded; late elements are elements which arrive after the Watermark has reached the operator.
Cheers, Max On Thu, Jul 28, 2016 at 6:49 PM, Kevin Jacobs <kevin.jac...@cern.ch> wrote: > Is it possible to discard events that are out-of-order (in terms of event > time)? >
