Re: Watermarks per key

Posted by jganoff on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Watermarks-per-key-tp11628p11761.html

There's nothing stopping me assigning timestamps and generating watermarks on a keyed stream in the implementation and the KeyedStream API supports it. It appears the underlying operator that gets created in DataStream.assignTimestampsAndWatermarks() isn't key-aware and globally tracks timestamps. So is that what's technically preventing assigning timestamps per key from working?

I'm curious to hear Aljoscha's thoughts on watermark management across keys.

Thanks!