[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15136704#comment-15136704
]
Maximilian Michels commented on FLINK-1502:
-------------------------------------------
I was working on this in FLINK-3170 but priorities have shifted a bit so I
haven't completed the work yet.
After I tied the initial collection of metrics to the existing runtime, I
realized that it would be better to build an abstraction for publishing the
metrics. What I did is to replace the accumulator {{HashMap}}s with a custom
{{TaskAccumulator}} type. In the runtime implementation, the actual
implementation can trigger publishing of the metrics during runtime. It would
suffice to register the accumulators once and then have them pulled in by the
BeanServer of the JVM.
This approach wouldn't touch too many runtime classes or introduce an extra
synchronization between the runtime thread and a metrics thread. All
non-job-related metrics which are published through the task managers (and
heartbeated to the job manager), can be exposed much more easily.
> Expose metrics to graphite, ganglia and JMX.
> --------------------------------------------
>
> Key: FLINK-1502
> URL: https://issues.apache.org/jira/browse/FLINK-1502
> Project: Flink
> Issue Type: Sub-task
> Components: JobManager, TaskManager
> Affects Versions: 0.9
> Reporter: Robert Metzger
> Priority: Minor
> Fix For: pre-apache
>
>
> The metrics library allows to expose collected metrics easily to other
> systems such as graphite, ganglia or Java's JVM (VisualVM).
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
