[
https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573804#comment-17573804
]
Chesnay Schepler commented on FLINK-28719:
------------------------------------------
Your test only works when the elements arrive at the window function in the
same order as in the original sequence.
But this is not the case since you are not setting a parallelism and the
MiniClusterWithClientResource isn't used properly; it will use some parallelism
> 1, causing the {{mapWith}} to effectively shuffle values.
This results in the record/watermark streams being interlaced, resulting in
non-deterministic output.
> 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)
