Hi David,
Thanks for the reply. I think especially in an error/failure handler metrics
are important in order to have proper monitoring/alerting in such cases. Would
be awesome if this could be added to Flink at some point :).
Regards,
Lars
> Am 02.12.2021 um 18:13 schrieb David Morávek <d...@apache.org>:
>
> Hi Lars,
>
> quickly looking at the ES connector code, I think you're right and there is
> no way to do that :( In general I'd say that being able to expose metrics is
> a valid request.
>
> I can imagine having some kind of `RichActionRequestFailureHandler` with
> `{get|set}RuntimeContext` methods. More or less the same thing we already do
> with for example the `RichFunction`. This unfortunately requires some work on
> the Flink side.
>
> cc @Arvid
>
> On Thu, Dec 2, 2021 at 5:52 PM <lars.bachm...@posteo.de
> <mailto:lars.bachm...@posteo.de>> wrote:
> Hi,
>
> is there a way to expose custom metrics within an elasticsearch failure
> handler (ActionRequestFailureHandler)? To register custom metrics I need
> access to the runtime context but I don't see a way to access the
> context in the failure handler.
>
> Thanks and regards,
>
> Lars
