flink获取latencymarker有什么好的方法

[gsralex]

Hi，All
   想问下大家如果要展示Flink任务的当前延时情况，有什么比较好的方法吗？用LatencyMarker是否可以，用API/JMX层面来获取的histogram能否汇总成一个数字？

[shizk233]

如果是Data Stream API的话，可以考虑在目标算子上使用自定义metrics来展示数据延时情况

郭士榕 <[hidden email]> 于2020年9月26日周六 下午9:15写道：

> Hi，All
>
>  想问下大家如果要展示Flink任务的当前延时情况，有什么比较好的方法吗？用LatencyMarker是否可以，用API/JMX层面来获取的histogram能否汇总成一个数字？

[gsralex]

感谢答复，是Sql的任务，想用LatencyMarker，本身提交的Sql任务可能没有用到EventTime





在 2020-09-26 21:27:08，"shizk233" <[hidden email]> 写道：
>如果是Data Stream API的话，可以考虑在目标算子上使用自定义metrics来展示数据延时情况
>
>郭士榕 <[hidden email]> 于2020年9月26日周六 下午9:15写道：
>
>> Hi，All
>>
>>  想问下大家如果要展示Flink任务的当前延时情况，有什么比较好的方法吗？用LatencyMarker是否可以，用API/JMX层面来获取的histogram能否汇总成一个数字？

[JasonLee]

hi

LatencyMarker 是一个全链路的延迟 不是非常的准确 不过也能大致反应端到端的延迟情况



-----
Best Wishes
JasonLee
--
Sent from: http://apache-flink.147419.n8.nabble.com/

[ying]

Latency tracking[1] 开启后，metrics 里的 [<source_id>.[<source_subtask_index>.]]<operator_id>.<operator_subtask_index>.latency 值只能作为一个参考值，更适合根据对比值判断哪个 channel、operator 延时变高了。




sql 的话，也可能遇到之前我之前困惑的一点：http://apache-flink.147419.n8.nabble.com/flink-Latency-tracking-td1800.html 




所以如果是用于获取数据流 end-to-end 延迟的话，目前觉得还是在 sql 数据流里自己增加一个时间字段比较合适。

另外 source 是 kafka 的话 group 的 lag 值，checkpoint 的 lastCheckpointDuration 也都可以作为一个参考




1: https://ci.apache.org/projects/flink/flink-docs-master/monitoring/metrics.html#latency-tracking














在 2020-09-26 21:30:24，"郭士榕" <[hidden email]> 写道：

>感谢答复，是Sql的任务，想用LatencyMarker，本身提交的Sql任务可能没有用到EventTime
>
>
>
>
>
>在 2020-09-26 21:27:08，"shizk233" <[hidden email]> 写道：
>>如果是Data Stream API的话，可以考虑在目标算子上使用自定义metrics来展示数据延时情况
>>
>>郭士榕 <[hidden email]> 于2020年9月26日周六 下午9:15写道：
>>
>>> Hi，All
>>>
>>>  想问下大家如果要展示Flink任务的当前延时情况，有什么比较好的方法吗？用LatencyMarker是否可以，用API/JMX层面来获取的histogram能否汇总成一个数字？