Hi Eugen,
It is true that for ITcases this can be difficult and this should be improved
in Flink’s testing infrastructure,
but for this specific PR, what you need to check is if the allowedLateness
parameter is propagated correctly
throughout the translation process. The window operator with all
Hi devs
During the work on https://issues.apache.org/jira/browse/FLINK-10050 I've
found unstable behaviour of unit tests for unioned streams (which are used
in CoGroupedStream/JoinedStream under the hood).
Let's assume we have late elements in one of the stream. The thing is we
have no guarantees
