Fllink Web UI不显示在自定义源实现中收到的记录

Question

我已经构建了一个自定义源来处理Flink中的日志流.程序运行正常,在处理完记录后给出了我想要的结果.

但是,当我检查Web UI时,我没有看到计数.以下是截图: 记录/字节数

Answer 1

Flink将您管道的所有运营商链接到一个运营商:Source -> FlatMap -> ProcessLog -> Sink.因此,该单个运算符包含源和接收器.此外,Flink既不能测量源读取的字节数,也不能测量接收器写入的字节数.它只能测量运营商之间发送的字节数.由于源和接收器在同一个运算符中执行,因此Web UI不会向您显示发送/接收的任何字节.