I guess my logs suggest this is simply what a KeyedStream does by default, I guess I was just trying to find a doc that said that rather than relying on my logs.
From: Philip Doctor <philip.doc...@physiq.com> Date: Tuesday, December 12, 2017 at 5:50 PM To: "user@flink.apache.org" <user@flink.apache.org> Subject: Calling an operator serially I’ve got a KeyedStream, I only want max parallelism (1) per key in the keyed stream (i.e. if key is OrganizationFoo then only 1 input at a time from OrganizationFoo is processed by this operator). I feel like this is obvious somehow, but I’m struggling to find the docs for this. Can anyone point me the right way here?
