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 ranasinghe <dhanuka.priyan...@gmail.com> 写道:
> 
> patternStream

Reply via email to