Re: Race between window assignment and same window timeout

Hi Shay, This sounds very much like the off-by-one bug described by FLINK-9857 [1]. The problem was identified in another recent user ml thread and fixed for Flink 1.5.2 and 1.6.0. Best, Fabian [1] https://issues.apache.org/jira/browse/FLINK-9857 2018-07-18 19:00 GMT+02:00 Andrey Zagrebin : >

Re: Race between window assignment and same window timeout

Hi Shay, I would suggest to try Allowed Lateness, like you mention 500 ms: https://ci.apache.org/projects/flink/flink-docs-release-1.5/dev/stream/operators/windows.html#allowed-lateness

Race between window assignment and same window timeout

Hi, It seems like we encounter a race situation between the aggregation thread and the Time Trigger thread. It might not be a bug, but it still seems strange to us, and we would like your help to fix it/work around it please. First, few descriptions about our use case and system: · We