flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Greg Hogan <c...@greghogan.com>
Subject Re: Metrics not reported to graphite
Date Thu, 01 Sep 2016 22:04:05 GMT
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 <jackhuang@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
>

Mime
View raw message