Hello, I am facing a problem where KeyedStream is purely parallelised on workers for case where number of keys is close to parallelism.
Some workers process zero keys, some more than one. This is because of `KeyGroupRangeAssignment.assignKeyToParallelOperator()` in `KeyGroupStreamPartitioner` as I found out in this post: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Use-keyBy-to-deterministically-hash-each-record-to-a-processor-task-slot-td16483.html I would like to find out what are my options here. * is there a reason why custom partitioner can not be used in keyed stream? * can there be an API support for creating keys correct KeyedStream compatible keys? It would also make `DataStreamUtils.reinterpretAsKeyedStream()` more useable for certain scenarios. * any other option I have? Many thanks in advance. Best, Jozef
