Hi Max,
Thanks for the answer.
I needed to ensure that in a parallel window operation (which relies on a
KeyedStream) each partition contains a single key, in the output stream of the
window.
I can obtain this using a customPartitioner just after the window, but relying
on the partitioner of th
Hi Philippe,
There is no particular reason other than hash partitioning is a
sensible default for most users. It seems like this is rarely an
issue. When the number of keys is close to the parallelism, having
idle partitions is usually not a problem due to low data volume. I see
that it could be a
