Hey all, I observed what appears to be a change in behavior for EventTimeSessionWindows when upgrading from 1.11.1 to 1.14.0. This was identified in a unit test.
For a window with a defined time gap of 10 seconds. - Publish KEY_1 with eventtime 1 second - Publish KEY_1 with eventtime 3 seconds - Publish KEY_1 with eventtime 2 seconds - Publish KEY_2 with eventtime 101 seconds For Flink 1.11.1 the window for KEY_1 closes, reduces, and publishes, supposedly because KEY_2 had an event time greater than 10 seconds after the last message in KEY_1's window. KEY_2 window would also not close. In the absence of KEY_2 the KEY_1 window would not close. For Flink 1.14.0 the main difference is that the window for KEY_2 *DOES* close even though there are no new messages after 111 seconds. This appears to be a change in behavior. The nearest I could find was https://issues.apache.org/jira/browse/FLINK-20443 but that’s in 1.14.1. Is there an explanation for this change in behavior? Is it expected or desirable? Is it because all pending windows are automatically closed based on an updated trigger behavior? I tested the same behavior for ProcessingTimeSessionWindows and did not observe a similar change in behavior. Thanks. Jai
