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