[ https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
zhuhaifeng updated FLINK-4840: ------------------------------ Description: We should expose the following Metrics on the TaskIOMetricGroup: 1. recordProcessLatency(ms): Histogram measuring the processing time per record of a task. It is the processing time of chain if a chained task. 2. recordProcTimeProportion(ms): Meter measuring the proportion of record processing time for infor whether the main cost was: 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 > 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 TaskIOMetricGroup: > 1. recordProcessLatency(ms): Histogram measuring the processing time per > record of a task. It is the processing time of chain if a chained task. > 2. recordProcTimeProportion(ms): Meter measuring the proportion of record > processing time for infor whether the main cost -- This message was sent by Atlassian JIRA (v6.3.4#6332)