Fllink Web UI 不显示自定义源实现中收到的记录 [英] Fllink Web UI not displaying records received in a Custom Source implementation

问题描述

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

I have build a custom source to process a log stream in Flink. The program is running fine and giving me the desired results after processing the records.

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

But, when I check the Web UI, I do not see the counts. Below is the screenshot: Records/Bytes Count

推荐答案

Flink 将你管道的所有操作符链接成一个操作符:Source ->平面地图 ->进程日志 ->接收器.因此，这个单一的算子包含源和汇.此外，Flink 既不能测量源读取的字节数，也不能测量接收器写入的字节数.它只能测量运营商之间发送的字节数.由于源和接收器在同一个运算符中执行，因此 Web UI 不会向您显示发送/接收的任何字节.

Flink chained all the operators of your pipeline into one operator: Source -> FlatMap -> ProcessLog -> Sink. Thus, this single operator contains the source and the sink. Additionally, Flink can neither measure the amount of bytes read by a source nor the number of bytes written by a sink. It can only measure the bytes sent between operators. Since the source and sink are executed in the same operator, the web UI does not show you any bytes sent/received.

这篇关于Fllink Web UI 不显示自定义源实现中收到的记录的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！