[ https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chesnay Schepler closed FLINK-28719. ------------------------------------ Resolution: Information Provided > Mapping a data source before window aggregation causes Flink to stop handle > late events correctly. > -------------------------------------------------------------------------------------------------- > > Key: FLINK-28719 > URL: https://issues.apache.org/jira/browse/FLINK-28719 > Project: Flink > Issue Type: Bug > Components: API / DataStream > Affects Versions: 1.15.1 > Reporter: Mykyta Mykhailenko > Priority: Major > > I have created a > [repository|https://github.com/mykytamykhailenko/flink-map-with-issue] where > I describe this issue in detail. > I have provided a few tests and source code so that you can reproduce the > issue on your own machine. -- This message was sent by Atlassian Jira (v8.20.10#820010)