Apache Beam Counter/Metrics 在 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.Counter;导入 org.apache.beam.sdk.metrics.Metrics;...Counter elementsRead = Metrics.counter(getClass(), "elements_read");...elementRead.inc();

但我在 Flink WebUI 中的任何地方(任务指标或累加器)都找不到 "elements_read" 计数.我认为在

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 Beam Counter/Metrics 在 Flink WebUI 中不可用的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！