Hi Greg, Following your hint, I found the solution here (https://issues.apache.org/ jira/browse/FLINK-4396) and resolved the issue. I had to put all three jars to the lib directory to get it to work.
A follow up questions: can I put a prefix (e.g. flink) to all flink metrics instead of having their names starting with the host ip address? Thanks, Jack On Thu, Sep 1, 2016 at 3:04 PM, Greg Hogan <c...@greghogan.com> wrote: > Have you copied the required jar files into your lib/ directory? Only JMX > support is provided in the distribution. > > On Thu, Sep 1, 2016 at 5:07 PM, Jack Huang <jackhu...@mz.com> wrote: > >> Hi all, >> >> I followed the instruction for reporting metrics to a Graphite server on >> the official document (https://ci.apache.org/project >> s/flink/flink-docs-release-1.1/apis/metrics.html#metric-types). >> >> Specifically, I have the following config/code in my project >> >> >> metrics.reporters: graphite >> metrics.reporter.graphite.class: >> org.apache.flink.metrics.graphite.GraphiteReporter >> metrics.reporter.graphite.host: node12 >> metrics.reporter.graphite.port: 2003 >> >> >> >> events.filter(new RichFilterFunction[Event]() { >> lazy val incomingCounter = >> getRuntimeContext.getMetricGroup.counter("event.incoming") >> lazy val downsampledCounter = >> getRuntimeContext.getMetricGroup.counter("event.downsampled") >> def filter(event:Event):Boolean = { >> incomingCounter.inc >> if(!event.bid_id.startsWith("0")) { >> return false; >> } >> downsampledCounter.inc >> return true; >> } >> }) >> >> >> >> However I don't see anything on my graphite server. What am I missing? >> >> >> Thanks, >> Jack >> > >
