Hi, Flink currently performs a 128-bit murmur hash on the user-provided uids to generate the final node hashes in the stream graph. Specifically, this library is being used [1] as the hash function.
If what you are looking for is for Flink to use exactly the provided hash, you can use `setUidHash` for that - Flink will use that provided uid hash as is for the generated node hashes. However, that was exposed as a means for manual workarounds to allow for backwards compatibility in legacy breaking cases, so it is not advised to use that in your case. BR, Gordon [1] https://guava.dev/releases/19.0/api/docs/com/google/common/hash/Hashing.html#murmur3_128(int) -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/