Hi Biplob, You are correct that only a higher watermark leads to discarded events. Are you sure that your custom watermark emitter does not emit a high watermark? E.g. your partition has elements that are far out-of-order.
In addition, are you sure that your elements are not simply buffered and waiting for the right watermark? Kostas > On Jun 20, 2017, at 2:03 PM, Biplob Biswas <revolutioni...@gmail.com> wrote: > > But if that's the case, I don't understand why some of my events are just > lost .... If the watermark which is used is the smallest ... They either I > expect a match or I expect a timed out event. > > The only way I can imagine my events getting lost is higher watermark than > the incoming event and thus that event is discarded as too late. > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-CEP-not-emitting-timed-out-events-properly-tp13794p13854.html > Sent from the Apache Flink User Mailing List archive. mailing list archive at > Nabble.com.
