Fwd: Flink metrics with parallel operator

[Biao Liu]

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 <[hidden email]>
Date: Thu, Aug 1, 2019 at 2:42 AM
Subject: Flink metrics with parallel operator
To: <[hidden email]>

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