Hi there! I am tracking the latency of my operators using "setLatencyTrackingInterval(10000)" and I can see the latency metrics on the browser http://127.0.0.1:8081/jobs/<JOB_ID>/metrics . For each logical operator I set a .uid("operator_name") and I know that Flink uses the UidHash to create a string for each operator. For example my operator "A" has the hash code "2e588ce1c86a9d46e2e85186773ce4fd".
What is the hash function used to define this hash code? I want to use the same hash function to be able to automatically monitor the 99th percentile latency. AFAIK, Flink does not provide a way to create an operator ID that has the operator name included [1][2]. Is there a specific reason for that? [1] https://issues.apache.org/jira/browse/FLINK-8592 [2] https://issues.apache.org/jira/browse/FLINK-9653 *--* *-- Felipe Gutierrez* *-- skype: felipe.o.gutierrez* *--* *https://felipeogutierrez.blogspot.com <https://felipeogutierrez.blogspot.com>*
