Я создал собственный источник для обработки потока журнала во Flink. Программа работает нормально и дает мне желаемые результаты после обработки записей.
Но когда я проверяю веб-интерфейс, я не вижу счетчиков. Ниже приведен снимок экрана: Количество записей/байт
Flink объединил всех операторов вашего пайплайна в одного оператора: Source -> FlatMap -> ProcessLog -> Sink. Таким образом, этот единственный оператор содержит источник и приемник. Кроме того, Flink не может измерить ни количество байтов, прочитанных источником, ни количество байтов, записанных приемником. Он может только измерять байты, отправленные между операторами. Поскольку источник и приемник выполняются одним и тем же оператором, веб-интерфейс не показывает никаких отправленных/полученных байтов.
