flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yunus Olgun <yunol...@gmail.com>
Subject CoGroupedStreams.WithWindow sideOutputLateData and allowedLateness
Date Mon, 28 Aug 2017 15:09:49 GMT

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?

View raw message