Re: Beam runner statsd metrics

2019-11-08 Thread Kush Kumar Sharma
and utilize the Flink statsd reporter: > > https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/metrics.html#statsd-orgapacheflinkmetricsstatsdstatsdreporter > > Cheers, > Max > > [1] > > https://beam.apache.org/releases/javadoc/2.1.0/org/apache/beam/sdk/metric

Beam runner statsd metrics

2019-11-08 Thread Kush Kumar Sharma
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