Apache光束计数器/度量标准在Flink WebUI中不可用 [英] Apache Beam Counter/Metrics not available in Flink WebUI

问题描述

我正在使用Flink 1.4.1和Beam 2.3.0，并且想知道是否可以在Flink WebUI（或任何地方）中提供指标，如Dataflow WebUI？

我使用的计数器如下：

  import org.apache.beam.sdk.metrics 。计数器; 
 import org.apache.beam.sdk.metrics.Metrics; 
 ... 
 Counter elementsRead = Metrics.counter（getClass（），elements_read）; 
 ... 
 elementsRead.inc（）; 
  

但我找不到elements_read Flink WebUI中可用的任何位置（任务度量或累加器）。在

I'm using Flink 1.4.1 and Beam 2.3.0, and would like to know is it possible to have metrics available in Flink WebUI (or anywhere at all), as in Dataflow WebUI ?

I've used counter like:

import org.apache.beam.sdk.metrics.Counter;
import org.apache.beam.sdk.metrics.Metrics;
...
Counter elementsRead = Metrics.counter(getClass(), "elements_read");
...
elementsRead.inc();

but I can't find "elements_read" counts available anywhere (Task Metrics or Accumulators) in Flink WebUI. I thought this will be straightforward after BEAM-773.

解决方案

Once you have selected a job in your dashboard, you will see the DAG for that job and below the DAG there are a list of tabs.

1. Click on "Task Metrics" Tab
2. Click on a box of your DAG
3. Click on the Add Metric Button, to show that operator metric

这篇关于Apache光束计数器/度量标准在Flink WebUI中不可用的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！