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
