Hi community,

I am tracking the latency of operators in Flink according to this reference
[1]. When I am using Prometheus+Grafana I can issue a query using
"flink_taskmanager_job_latency_source_id_operator_id_operator_subtask_index_latency"
and I can check the percentiles of each "operator_id" and each
"operator_subtask_index". Each "operator_subtask_index" means each instance
of the parallel physical operator, doesn't it?

How can I set a fixed ID for the "operator_id" in my code so I can identify
quickly which operator I am measuring? I used "map(new
MyMapUDF()).uid('my-operator-ID')" but it seems that there is a hash
function that converts the string to a hash value. What is the hash
function used so I can identify my operator? I know that I can use the Rest
API [2] and if I name my operator it will have always the same hash when I
restart the job, but I would like to set its name.

[1]
https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/metrics.html#latency-tracking
[2]
https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/metrics.html#rest-api-integration
*-*
*- Felipe Gutierrez*

*- skype: felipe.o.gutierrez*
*- **https://felipeogutierrez.blogspot.com
<https://felipeogutierrez.blogspot.com>* *
<https://felipeogutierrez.blogspot.com>*

Reply via email to