Hi all :
As it described above , “<source_id>.<source_subtask_index>.<operator_id>.<operator_subtask_index>.latency” means “The latency distributions from a given source subtask to an operator subtask (in milliseconds).” But when i get flink metrics by using graphite, i found the metrics value of different operator are the same! What make me more confused is that when i compare two different flink job , the values are all the same too! I want to know how this value is calculated and why the collected values are the same.
Can someone help me to explain that ? Appreciate it
Thanks
Hanmiao Li