Apache光束计数器/度量标准在Flink WebUI中不可用

Question

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

我用过像这样的柜台:

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

但我无法"elements_read"在Flink WebUI中找到任何可用的计数(任务指标或累加器).我认为在BEAM-773之后这将是直截了当的.

Answer 1

在仪表板中选择作业后，您将看到该作业的 DAG，并且 DAG 下方有一个选项卡列表。

1. 单击“任务指标”选项卡
2. 单击 DAG 的方框
3. 单击“添加指标”按钮，显示该操作员指标