Hi, I'm afraid this is impossible with the current design of Flink. Might I ask what you want to achieve with this? Maybe we can come up with a solution.
-Aljoscha On Tue, 31 May 2016 at 13:24 <leon_mcl...@tutanota.com> wrote: > My use case primarily concerns applying transformations per key, with the > keys remaining fixed throughout the topology. I am using event time for my > windows. > > The problem i am currently facing is that watermarks in windows propagate > per operator instance, meaning the operator event time increases for all > keys that the operator is in charge of. I wish for watermarks to progress > per key, not per operator instance. > > Is this easily possible? I was unable to find an appropriate solution > based on existing code recipes. > > Greetings > Leon >
