谢谢解答,如果是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.