You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by "casel.chen" <ca...@126.com> on 2023/06/12 09:05:16 UTC

求flink作业各个算子的延迟指标

想统计数据经过flink作业各个算子的延迟指标，目前社区开源版能实现吗？

Re:Re: 求flink作业各个算子的延迟指标

Posted by "casel.chen" <ca...@126.com>.

谢谢解答，如果是flink sql作业要如何获取到作业中每个算子的latency指标呢？
而且通过prometheus获取作业指标的话，因为flink sql作业中每个算子的名称是按sql内容拼出来的，会出现名称很长，
这样的算子指标直接打到prometheus的话会直接将prometheus内存打爆，这个问题有什么好的办法解决吗？

















在 2023-06-12 18:01:11，"Hangxiang Yu" <ma...@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 <ca...@126.com> wrote:
>
>> 想统计数据经过flink作业各个算子的延迟指标，目前社区开源版能实现吗？
>
>
>
>-- 
>Best,
>Hangxiang.

Re: 求flink作业各个算子的延迟指标

Posted by Hangxiang Yu <ma...@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 <ca...@126.com> wrote:

> 想统计数据经过flink作业各个算子的延迟指标，目前社区开源版能实现吗？



-- 
Best,
Hangxiang.