Re: Question about Flink Metrics

2017-09-26 Thread Tony Wei
Hi Chesnay, That sounds great to me. I think I will be interested in it. Best Regards, Tony Wei 2017-09-26 21:57 GMT+08:00 Chesnay Schepler : > Hello, > > i see the value in supporting this, and it's also quite easy to do so > actually. > > I've filed FLINK-7692, containing instructions on how

Re: Question about Flink Metrics

2017-09-26 Thread Chesnay Schepler
Hello, i see the value in supporting this, and it's also quite easy to do so actually. I've filed FLINK-7692, containing instructions on how to implement this. @Tony Are you interested in implementing this? On 26.09.2017 14:10, Tony Wei wrote: Hi Hai Zhou, It's a good idea to implement my

Re: Question about Flink Metrics

2017-09-26 Thread Tony Wei
Hi Hai Zhou, It's a good idea to implement my own reporter, but I think it is not the best solution. After all, reporter needs to be set well when starting the cluster. It is not efficient to update cluster whenever you have a new metric for a new streaming job. Anyway, it is still a workaround f

Re: Question about Flink Metrics

2017-09-26 Thread Hai Zhou
Hi Tony, you can consider implementing a reporter, use a trick to convert the flink's metrics to the structure that suits your needs. This is just my personal practice, hoping to help you. Cheers, Hai Zhou > 在 2017年9月26日,17:49,Tony Wei 写道: > > Hi, > > Recently, I am using PrometheusReporte

Question about Flink Metrics

2017-09-26 Thread Tony Wei
Hi, Recently, I am using PrometheusReporter to monitor every metrics from Flink. I found that the metric name in Prometheus will map to the identifier from User Scope and System Scope [1], and the labels will map to Variables [2]. To monitor the same metrics from Prometheus, I would like to use