Re: Flink 1.3.2 with CEP Pattern, Memory usage increases results in OOM

[Kostas Kloudas]

Hi Abiramalakshmi,

Thanks for reporting this!

As a starting point I would recommend:

1) use RocksDB as your backend, so that state is not accumulated in memory
2) enable incremental checkpoints
3) the “new IterativeCondition<DeviceCheckInEvent>() {…}” can become “new 
SimpleCondition<DeviceCheckInEvent>() {}”, 
    as this is more efficient
4) set the default watermark interval to a small value so that you have 
frequent watermarks and elements are not 
   accumulated.

If you do the above, please let me know if the problems persist.

Thanks,
Kostas


> On Apr 10, 2018, at 1:19 PM, Abiramalakshmi Natarajan 
> <abirami.natara...@gmail.com> wrote:
> 
> new Iter