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 

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


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

Reply via email to