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
Hi there!
I am tracking the latency of my operators using
"setLatencyTrackingInterval(1)" and I can see the latency metrics on
the browser http://127.0.0.1:8081/jobs//metrics . For each logical
operator I set a .uid("operator_name") and I know that Flink uses the
UidHash to create a string
