[
https://issues.apache.org/jira/browse/FLINK-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15607919#comment-15607919
]
ASF GitHub Bot commented on FLINK-4923:
---------------------------------------
GitHub user zhuhaifengleon opened a pull request:
https://github.com/apache/flink/pull/2693
[FLINK-4923] [Metrics] Expose input/output buffers and bufferPool usa…
The buffers and buffer usage of Input/output bufferPool for a task reflect
wether a task congestion.
So we expose the following Metrics as a Buffers MetricGroup on the
TaskIOMetricGroup, all these metrics is a gauge.
1. numIn of Buffers: received buffers of all InputGates of a task
2. numOut of Buffers: buffers of all produced ResultPartitions of a task
3. InPoolUsage of Buffers: bufferPool usage of all InputGates of a task
4. OutPoolUsage of Buffers: bufferPool usage of all produced
ResultPartitions of a task
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/zhuhaifengleon/flink FLINK-4923
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2693.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 #2693
----
commit 3beb65b8b3ee13d9901763c0fc2138613a36d154
Author: zhuhaifengleon <[email protected]>
Date: 2016-10-26T07:48:31Z
[FLINK-4923] [Metrics] Expose input/output buffers and bufferPool usage as
a metric for a Task
----
> Expose input/output buffers and bufferPool usage as a metric for a Task
> -----------------------------------------------------------------------
>
> Key: FLINK-4923
> URL: https://issues.apache.org/jira/browse/FLINK-4923
> 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. Buffers.numIn: received buffers of InputGates for a task
> 2. Buffers.numOut: buffers of produced ResultPartitions for a task
> 3. Buffers.InPoolUsage: usage of InputGates buffer pool for a task
> 4. Buffers.OutPoolUsage: usage of produced ResultPartitions buffer pool for
> a task
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
