5

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

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

4

1 回答 1

11

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

于 2016-01-11T14:50:57.747 回答