[jira] [Commented] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly.

[ https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17578890#comment-17578890 ] Chesnay Schepler commented on FLINK-28719: -- > As far as I understand, op1 and op2 should have

[jira] [Commented] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly.

[ https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17578858#comment-17578858 ] Mykyta Mykhailenko commented on FLINK-28719: Actually, I think I hurried a little. Could you

[jira] [Commented] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly.

[ https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576745#comment-17576745 ] Mykyta Mykhailenko commented on FLINK-28719: Sorry I haven't answered you earlier

[jira] [Commented] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly.

[ https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17573809#comment-17573809 ] Chesnay Schepler commented on FLINK-28719: -- So let's dive into what is happening. The source

[jira] [Commented] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly.

[ https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17573804#comment-17573804 ] Chesnay Schepler commented on FLINK-28719: -- Your test only works when the elements arrive at