Metrics not reported to graphite

[Jack Huang]

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