Fwd: Flink metrics with parallel operator

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view

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.

---------- 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]>


I have been working on a flink project and need some help with the metric

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?