Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1157#issuecomment-141985771
This looks promising. However, how can `CountMetric` be used (without any
changes to the Spout/Bolt code within Flink? Right now it seems, that the user
has to replace `CountMetric` with `FlinkCountMetric` in `open()/prepare()`
method. However, the user code should be unchanged and the counter should be
collected by Flink under the hood, and translated into a Flink accumulator
transparently to the user. I found a nice example on the usage of metrics in
Storm: https://www.endgame.com/blog/storm-metrics-how Maybe you try to run this
code just changing `TopologyBuilder` to `FlinkTopologyBuilder` and omitting the
metric consumer for now.
---
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.
---
