flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chesnay Schepler <ches...@apache.org>
Subject Re: Flink - Metric are not reported
Date Tue, 27 Nov 2018 16:07:11 GMT
Please enable WARN logging and check for warnings by the SLF4JReporter 
and/or MetricQueryService.

On 27.11.2018 17:00, bastien dine wrote:
> Hello everyone,
>
> Once again I require your help !
> I am trying to report custom metric (see my code below)
> Yet, I do not see them anywhere.. nor in the metric tab from my tasks, 
> nor in the rest API, nor in the declared slf4j reporter..
> Can someone help me to debug this ..
>
> Here is my RichMap function :
> public class MetricGaugeRichMap<T,E extends MetricTuple<T>> extends RichMapFunction<E,E>
{
>
>      private transient T valueToExpose;
>      private final StringmetricGroup;
>      private final StringmetricName;
>
>
>      public MetricGaugeRichMap(String metricGroup, String metricName) {
>          this.metricGroup = metricGroup;
>          this.metricName = metricName;
>      }
>
>      @Override public void open(Configuration config) {
>          getRuntimeContext()
>                  .getMetricGroup()
>                  .addGroup(metricGroup)
>                  .gauge(metricName, (Gauge<T>) () -> valueToExpose);
>      }
>
>      @Override public E map(E metricTuple)throws Exception {
>          valueToExpose = metricTuple.getMetricValue();
>          return metricTuple;
>      }
> }
> calling from topology :
> env.fromElements(new MetricTuple<>(metricGroup,metricName,metricValue))
>      .map(new MetricGaugeRichMap<>(metricGroup,metricName))
>      .output(new MetricGaugeOutputFormat<>()); // dummy output
> ------------------
>
> Bastien DINE
> Data Architect / Software Engineer / Sysadmin
> bastiendine.io <http://bastiendine.io>



Mime
View raw message