为什么 Flink Dashboard 不显示从源接收或写入接收器的记录数？

Question

Flink 仪表板很棒，它显示了许多正在运行的作业的详细信息。然而，我注意到的一件事是，作业的源和接收器将分别以0 显示接收的记录和发送的记录。

现在我知道他们仍在工作之外接收和发送记录，但 0 往往会让人们非常困惑。选择这样是有原因的吗？或者有什么办法让它不是0？

特别是对于接收器，如果序列化架构无法序列化消息（并且错误被捕获并记录，而不是导致作业失败），您将看不到接收器实际输出的数字来反映这一点。你总是会看到0 并且会假设一切都通过了。

Answer 1

原因是我们不能以一种通用的方式来衡量这一点，并且必须分别在我们还没有找到时间的每个源/接收器中实施测量。另一个问题是，这必须在用户定义的函数中完成，但相关指标无法从那里访问（目前）。

见https://issues.apache.org/jira/browse/FLINK-7286。