[
https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15635541#comment-15635541
]
ASF GitHub Bot commented on FLINK-4840:
---------------------------------------
GitHub user zhuhaifengleon opened a pull request:
https://github.com/apache/flink/pull/2753
[FLINK-4840] [metrics] Measure latency of record processing and expose it
as a metric
This PR introduce record processing time metric for measuring a task
running performance. The latency is processing time cost of all chained
operator for a task.
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
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/zhuhaifengleon/flink FLINK-4840
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2753.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2753
----
commit 780d5590ff90ff6cda703b5747db01fc3bf968b9
Author: zhuhaifengleon <[email protected]>
Date: 2016-10-31T09:41:39Z
[FLINK-4840] [metrics] Measure latency/delay of record processing and
expose it as a metric
commit 0fbb87be7ec9b86edb0888203d00aec595e77b31
Author: zhuhaifengleon <[email protected]>
Date: 2016-11-03T08:26:29Z
[FLINK-4840] [metrics] 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 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)
