我已经建立了一个自定义源来处理Flink中的日志流。
但是,当我检查Web UI时,我看不到计数。以下是截图:
我已经建立了一个自定义源来处理Flink中的日志流。
但是,当我检查Web UI时,我看不到计数。以下是截图:
Flink将 pipeline 的所有操作符 chaining接到一个操作符中:Source->FlatMap->ProcessLog->Sink。因此,这个操作符包含源和汇。此外,Flink既不能测量源读取的字节数,也不能测量 sink写入的字节数。它只能测量运算符之间发送的字节数。因为源和 sink是在同一个操作符中执行的,所以web UI不会显示发送/接收的任何字节。