Re: Change In Behavior for EventTimeSessionWindow between Flink 1.11.1 and 1.14.0

2021-11-11 Thread Caizhi Weng
Hi! Did you specify source idleness time in watermark strategy? If yes source will be marked idle if no records are sent for a period of time, causing the 1.14 behavior you described. Could you also share your unit test case so we can take a deeper look? Jai Patel 于2021年11月12日周五 上午3:33写道: >

Change In Behavior for EventTimeSessionWindow between Flink 1.11.1 and 1.14.0

2021-11-11 Thread Jai Patel
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