Can you provide us a self-contained reproducing example? (preferably as
elementary as possible)
On 22.01.2019 18:58, dhanuka ranasinghe wrote:
Hi All,
I have used Flink CEP to filter some events and generate some alerts
based on certain conditions. But unfortunately doesn't print any
result.
Hi Dhanuka,
From the code you shared, it seems that you're using event time. The processing
of elements is triggered by watermark in event time and so you should define
how to generate the watermark, i.e with DataStream.assignTimestampsAndWatermarks
Regards,
Dian
> 在 2019年1月23日，上午1:58，dhanuka
Thank you for the clarification.
On Thu, 24 Jan 2019, 12:44 Dian Fu Hi Dhanuka,
>
> From the code you shared, it seems that you're using event time. The
> processing of elements is triggered by watermark in event time and so you
> should define how to generate the watermark, i.e with
> DataStream
