Hi all, Given that gradePeriodMs is "the time to admit late-arriving events after the end of the window", I'd expect it is taken into account in windowsFor(timestamp). E.g.:
sizeMs = 5 gracePeriodMs = 2 advanceMs = 3 timestamp = 6 | window | windowStart | windowEnd | windowsEnd + gracePeriod | | 1 | 0 | 5 | 7 | | 2 | 5 | 10 | 12 | ... Current output: windowsFor(timestamp) returns window 2 only. Expected output: windowsFor(timestamp) returns both window 1 and window 2 Do you agree with the expected output? Am I missing something? Regards, Jose