[
https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhuhaifeng updated FLINK-4840:
------------------------------
Summary: Measure latency of record processing and expose it as a metric
(was: Measure latency/delay of record processing and expose it as a metric)
> Measure latency of record processing and expose it as a metric
> --------------------------------------------------------------
>
> Key: FLINK-4840
> URL: https://issues.apache.org/jira/browse/FLINK-4840
> Project: Flink
> Issue Type: Improvement
> Components: Metrics
> Reporter: zhuhaifeng
> Assignee: zhuhaifeng
> Priority: Minor
> Fix For: 1.2.0
>
>
> We should expose the following Metrics on the OperatorIOMetricGroup:
> 1. latency(ms): record processing time as a histogram metric.
> 2. procTimeCostPerSecond(ms): record processing time accumulated per second,
> it measure record processing percentage to check if it's a main time costing
> 3. delay(ms): the time between upstream emit record and downstream start
> record processing
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
