Hi Sibendu, Have you checked the document of metrics[1]? It might be helpful.
BTW, I think it's better to ask in user mailing list. So forward it there. 1. https://ci.apache.org/projects/flink/flink-docs-master/monitoring/metrics.html#system-scope ---------- Forwarded message --------- From: Sibendu Dey <sibendu....@gmail.com> Date: Thu, Aug 1, 2019 at 2:42 AM Subject: Flink metrics with parallel operator To: <d...@flink.apache.org> Hello, I have been working on a flink project and need some help with the metric system. I have a logic inside a process function which side outputs a particular message on certain failure parameters. This process function has a parallelism > 1. How do I keep track of the failed messages through a counter metrics which is scoped to the operator across all parallel instances? Regards, Sibendu
