我已经建立了一个自定义源来处理flink中的日志流。程序运行良好，处理完记录后给了我想要的结果。但是，当我检查web ui时，我看不到计数。下面是截图：记录/字节计数
f0brbegy1#
flink把你的管道的所有操作员都锁在一个操作员身上： Source -> FlatMap -> ProcessLog -> Sink . 因此，这个操作符包含源和汇。此外，flink既不能测量源读取的字节数，也不能测量接收器写入的字节数。它只能测量运算符之间发送的字节数。因为源和接收器是在同一个操作符中执行的，所以web ui不会显示发送/接收的任何字节。
Source -> FlatMap -> ProcessLog -> Sink
1条答案
按热度按时间f0brbegy1#
flink把你的管道的所有操作员都锁在一个操作员身上：
Source -> FlatMap -> ProcessLog -> Sink. 因此，这个操作符包含源和汇。此外，flink既不能测量源读取的字节数，也不能测量接收器写入的字节数。它只能测量运算符之间发送的字节数。因为源和接收器是在同一个操作符中执行的，所以web ui不会显示发送/接收的任何字节。