Как создать динамическую метрику во Flink

Question

Я хочу создать одну метрику, связанную с количеством ошибок, но на самом деле я хотел бы добавить несколько контекстных меток?Каков наилучший способ сделать это?датчик?Как динамически создать этот тип метрики во время выполнения задачи (потому что открытый метод невозможен, потому что слишком рано)?Заранее спасибо

Дэвид

Answer 1

Вы должны иметь возможность создавать метрику в любое время - просто сделайте это один раз для экземпляра оператора, прежде чем использовать его.

Для отчетов об ошибках вы можете найти побочные выводы также полезными.