at 5:50 PM
> *To: *"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
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
Date: Tuesday, December 12, 2017 at 5:50 PM
To: "user@flink.apache.org"
Subject: Calling an operato
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 poi
