GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/3348
[FLINK-5090] [network] Add metrics for details about inbound/outbound
network queues
These metrics are optimised go go through the channels only once in order to
gather all metrics, i.e. min, max, avg and sum. Whenever a request to either
of those is made, all metrics are refreshed and cached. Requests to the
other
metrics will be served from the cache. However, each value will be served
only
once from the cache and a second call to retrieve the minimum, for example,
will refresh the cache for all values.
This setup may at first be a bit strange but ensures that the statistics
belong
together logically and originate from a common point in time. This is not
necessarily the point in time the metric was requested though.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/NicoK/flink flink-5090
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3348.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 #3348
----
commit 59e64c4187c8533e0d802bf415e289624db99f06
Author: Stephan Ewen <[email protected]>
Date: 2016-11-17T18:36:56Z
[FLINK-5090] [network] Add metrics for details about inbound/outbound
network queues
These metrics are optimised go go through the channels only once in order to
gather all metrics, i.e. min, max, avg and sum. Whenever a request to either
of those is made, all metrics are refreshed and cached. Requests to the
other
metrics will be served from the cache. However, each value will be served
only
once from the cache and a second call to retrieve the minimum, for example,
will refresh the cache for all values.
This setup may at first be a bit strange but ensures that the statistics
belong
together logically and originate from a common point in time. This is not
necessarily the point in time the metric was requested though.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
