Hi Devs!

I am trying to use a *Statsd* client in beam to export some runner metrics.
I am able to extract out metrics from the base application but once the job
is submitted to its runner(in this case I am using *FlinkRunner*), statsd
client stops working. This is a streaming job and I need to extract out
those metrics continuously(like how many files are getting processed, etc).

Are there any helper classes for this particular use case in beam? If not,
are there any flink specific classes that I can use here? I have seen
*MetricResults*(from *FlinkRunnerResult*) but it looks like I can only use
that once the job is done not when in progress.

My current statsd client is https://github.com/tim-group/java-statsd-client

Kush Sharma

Reply via email to