Re: Best way to initialize a custom metric task for all task managers and job manager

2020-02-28 Thread Chesnay Schepler
A proper solution will required a custom Flink build, were you want to modify org.apache.flink.runtime.metrics.util.MetricUtils#instantiateProcessMetricGroup and org.apache.flink.runtime.metrics.util.MetricUtils#instantiateTaskManagerMetricGroup to add your custom metrics. This is where the

Best way to initialize a custom metric task for all task managers and job manager

2020-02-28 Thread Theo Diefenthal
Hi, >From my backend service, I appreciate to collect metrics about the log >messages, i.e. how many error and warn messages were printed over time, see >e.g. for Micrometer: [ >https://github.com/micrometer-metrics/micrometer/blob/master/micrometer-core/src/main/java/io/micrometer/core/instru