[ 
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)

Reply via email to