Hi Dawid, I just tried to change from CoProcessFunction with onTimer() to ProcessWindowFunction with Trigger and TumblingWindow. So I can key my stream by (id) instead of (id, eventTime). With this, I can use /reinterpretAsKeyedStream/, and hope that it would give better performance. I can also use the out of the box function sideOutputLateData() Not sure whether I would really be benefited from that.
Thanks and regards, Averell -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
