CoGroupedStreams.WithWindow sideOutputLateData and allowedLateness

Posted by Yunus Olgun on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/CoGroupedStreams-WithWindow-sideOutputLateData-and-allowedLateness-tp15196.html

Hi,

WindowedStream has sideOutputLateData and allowedLateness methods to handle late data. A similar functionality at CoGroupedStreams would have been nice. As it is, it silently ignores late data and it is error-prone.

- Is there a reason it does not exist?

- Any suggested workaround?