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/projects/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 >
