谢谢解答，如果是flink sql作业要如何获取到作业中每个算子的latency指标呢？ 而且通过prometheus获取作业指标的话，因为flink sql作业中每个算子的名称是按sql内容拼出来的，会出现名称很长， 这样的算子指标直接打到prometheus的话会直接将prometheus内存打爆，这个问题有什么好的办法解决吗？
在 2023-06-12 18:01:11，"Hangxiang Yu" <master...@gmail.com> 写道： >[<source_id>.[<source_subtask_index>.]]<operator_id>.<operator_subtask_index>.latency >这个应该可以满足需求？也可以设置不同的粒度。 >https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/ops/metrics/#io > >On Mon, Jun 12, 2023 at 5:05 PM casel.chen <casel_c...@126.com> wrote: > >> 想统计数据经过flink作业各个算子的延迟指标，目前社区开源版能实现吗？ > > > >-- >Best, >Hangxiang.
