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

Question

我已经构建了一个自定义源来处理Flink中的日志流。程序运行良好，在处理记录后给了我所需的结果。

但是，当我检查Web UI时，我看不到计数。下面是屏幕截图：记录/字节计数

Answer 1

Flink将管道的所有操作符链接到一个操作符中：Source -> FlatMap -> ProcessLog -> Sink。因此，这个单独的操作符包含源和汇。此外，Flink既不能测量源读取的字节数，也不能测量宿写入的字节数。它只能测量运算符之间发送的字节数。由于源和接收器在同一个运算符中执行，因此web UI不会显示任何发送/接收的字节。