#apache-flink
Вопрос:
Изменить: Решил проблему с помощью Prometheus reporter.
Я определил Graphite в качестве репортера метрик с помощью своего Flink (v1.13.2). Мой конвейер довольно прост. Он состоит из одного источника, одного оператора с сохранением состояния (простая агрегация окон) и одного приемника (в основном на основе операций). Я установил коэффициент параллельности равным 2. График трубопровода выглядит следующим образом:
Программа работает хорошо и дает правильные результаты. Однако, когда я вижу показатели, я вижу, что источник начал отправлять записи после запуска системы, даже несмотря на то, что мой приемник давал правильные результаты с начала задания. Вот график времени безотказной работы задания и номера записей источника. Насколько я понял, numRecordsOut источников Apache Flink должен начинаться с времени безотказной работы, так как мой приемник с самого начала давал правильные результаты.