flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jack Huang <jackhu...@mz.com>
Subject Re: Metrics not reported to graphite
Date Thu, 01 Sep 2016 22:46:50 GMT
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 <code@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 <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/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
>>
>
>

Mime
View raw message