Hi shashank, What version of flink are you using? Is it possible that you are hitting this issue: https://issues.apache.org/jira/browse/FLINK-7563 ?
Watermark semantics in CEP was buggy and events were processed only if its timestamp was lower than current watermark while it should be lower or equal. Best Dawid > On 3 Jan 2018, at 17:05, shashank agarwal <shashank...@gmail.com> wrote: > > ssed A with origTimestamp Y. (
signature.asc
Description: Message signed with OpenPGP
