Thanks for sharing! It is an interesting idea. The generalized watermark [1] introduced in DataStreamV2 might be sufficient to implement it. It'll be great if you could share more contexts on why this is useful in your pipelines.
[1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-467%3A+Introduce+Generalized+Watermarks Best, Zhanghao Chen ________________________________ From: Мосин Николай <mosin...@yandex.ru> Sent: Thursday, May 15, 2025 3:58 To: user@flink.apache.org <user@flink.apache.org> Subject: Keyed watermarks: A fine-grained watermark generation for Apache Flink I found paper https://scholar.google.com/scholar?q=10.1016/j.future.2025.107796 where described Keyed Watermarks that is what I need in my pipelines. Does anyone know is it planned to implement Keyed Watermarks in Flink and when?
