Re: How to register and send custom metrics from Flink?

2017-03-13 Thread Bowen Li
Hi Chesnay, You saved my day! Yes, the WordCount example runs too fast, about 20ms. I extended its running time, and also set

Re: How to register and send custom metrics from Flink?

2017-03-13 Thread Chesnay Schepler
Hello, yes, Flink can handle custom metrics. It is quite odd that you can see the system metrics but not your own; I don't see a problem with your code. How long is the job running? Since you create a metric for the flatMap operation the metric will only be exposed as long as the flatMap

How to register and send custom metrics from Flink?

2017-03-13 Thread Bowen Li
Hi guys, I'm retrying to send some app related custom metrics from Flink to Datadog via StatsD. I followed https://ci.apache.org/projects/flink/flink-docs- release-1.2/monitoring/metrics.html to set up flink-conf.yaml and test code like this // flink-conf.yaml metrics.reporters: