Re: Flink CEP issues

Hi Daiqing, Is it possible to share your job in order to reproduce the problem? Or at least a minimal example. If you see from the JIRA, there is another user in https://issues.apache.org/jira/browse/FLINK-6321 who had a similar problem but we

Flink CEP issues

Hi guys, We are using flink cep to detect pattern. Here is the exception we got: org.apache.flink.streaming.api.operators.InternalTimeServiceManager. advanceWatermark(InternalTimeServiceManager.java:107) at org.apache.flink.streaming.api.operators.AbstractStreamOperator. processWatermark(Abstract