This is great info. Looks like it uses murmur hash below the surface too
[1].
Thanks!
[1]
https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupRangeAssignment.java#L76
On Mon, Jan 18, 2021 at 1:38 AM Timo Walther wrote:
> Hi Rex,
>
> fo
Hi Rex,
for questions like this, I would recommend to checkout the source code
as well.
Search for subclasses of `StreamPartitioner`. For example, for keyBy
Flink uses:
https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitio
