我正在使用 Flink 1.4.1 和 Beam 2.3.0，并且想知道是否可以像在 Dataflow WebUI 中那样在 Flink WebUI(或任何地方)中使用指标？
我用过这样的计数器:
import org.apache.beam.sdk.metrics.Counter;
import org.apache.beam.sdk.metrics.Metrics;
...
Counter elementsRead = Metrics.counter(getClass(), "elements_read");
...
elementsRead.inc();
但我在 Flink WebUI 的任何地方(任务指标或累加器)都找不到可用的 "elements_read" 计数。我认为这在 BEAM-773 之后会很简单.
最佳答案
在仪表板中选择作业后，您将看到该作业的 DAG，并且在 DAG 下方有一个选项卡列表。
- 点击“任务指标”标签
- 点击您的 DAG 的一个框
- 单击“添加指标”按钮以显示该运算符指标
关于java - Apache Beam Counter/Metrics 在 Flink WebUI 中不可用，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/49013889/