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! -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Watermarks-per-key-tp11628p11761.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
