Beam has its own Metrics which are reported via the Flink metric
system. You may want to use those and utilize the Flink statsd reporter:
On 08.11.19 11:31, Kush Kumar Sharma wrote:
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