flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gwenhael Pasquiers <gwenhael.pasqui...@ericsson.com>
Subject RE: Programmatically get live values of accumulators
Date Tue, 03 Jan 2017 09:16:17 GMT
Indeed, that looks like what we need. We currently rely on flink 1.0.1, that feature might
be a good reason to update our flink version. I’ll test it. Many thanks ! !

From: Jamie Grier [mailto:jamie@data-artisans.com]
Sent: lundi 2 janvier 2017 20:56
To: user@flink.apache.org
Subject: Re: Programmatically get live values of accumulators

Hi Gwenhael,

I think what you actually want is to use the Apache Flink metrics interface.  See the following:

Sending metrics to StatsD is supported out-of-the-box.


On Mon, Jan 2, 2017 at 1:34 AM, Gwenhael Pasquiers <gwenhael.pasquiers@ericsson.com<mailto:gwenhael.pasquiers@ericsson.com>>
Hi, and best wishes for the year to come ☺

I’d like to be able to programmatically get the (live) values of accumulators in order to
send them using a statsd (or another) client in the JobManager of a yarn-deployed application.
I say live because I’d like to use that in streaming (24/7) applications, and send live
stats, I cannot way for the application to end.

I’ve seen that there is a json API (I’d prefer no to have my app poll itself).
I’ve seen some code on github (tests files) where it’s done using the underlying akka
framework, I don’t mind doing it the same way and creating an actor to get notifications
messages, but I don’t know the best way, and there probably is a better one.

Thanks in advance,



Jamie Grier
data Artisans, Director of Applications Engineering

View raw message