Hi Vinay, By setting the allowed_lateness to LongMax you are ok. Sorry I forgot that this was the default value.
Just a note (although you have it right in your code), in this case you should always FIRE_AND_PURGE and not just FIRE. In other case your state will keep growing as it is never garbage collected. Cheers, Kostas > On Oct 4, 2016, at 5:42 PM, vinay patil <vinay18.pa...@gmail.com> wrote: > > Long.MAX_VALUE
