flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chesnay Schepler <ches...@apache.org>
Subject Re: Custom Metrics Reporting in Flink
Date Tue, 03 Oct 2017 20:40:30 GMT
This doesn't sound like a proper use-case for the metric system, but for 
side-outputs with a dedicated sink.

My reasoning is that it sounds like you want to push data, whereas the 
metrics work by drawing a snapshot of all metrics
and writing them out, i.e. one value per metric.

On 03.10.2017 13:51, Rahul Raj wrote:
> Hi,
> Is there any good example for custom metrics reporting in Flink? I 
> tried to follow the documentation but failed to achieve the result. 
> Basically my task is to identify the corrupt records based on a 
> missing field and report the same via statsd reporter.
> Rahul Raj

View raw message