Are you sure that after incrementing the wm by 1sec, there is no element that will come with a timestamp smaller than this? Or, that after 10sec of inactivity, no element will come with such a timestamp?
Kostas > On Jun 20, 2017, at 4:18 PM, Biplob Biswas <revolutioni...@gmail.com> wrote: > > currentMaxTimestamp = currentMaxTimestamp + 1000;