Hello,
you are correct that metrics are not aggregated on the Task- or
JobManager. Their primary purpose is to expose fine-grained information
to an external metric system, which could then do aggregations if desired.
There are plans to aggregate metrics in the WebInterface though, like
the
Hi All
Based on my code reading, I have following understanding of the Metrics
and Accumulators.
1. Accumulators for a Flink JOB work like global counters. They are
designed so that accumulator values from different instances of Execution
Vertex can be combined. They are essentially
