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 -> FlatMap -> ProcessLog -> Sink.因此，该单个运算符包含源和接收器.此外，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屋！