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
> <[email protected]> wrote:
>
> new Iter
