Hi,
I just would like to confirm if using richAsyncFunction not recommended to
increment metrcs? Because the counter I have created does not correctly
increment its value. But it works using the RichMapFunction as an example
in the documentation.
I am using RichAsyncFunction to send data to exter
Apology.
The question is, from our understanding we do not need to implement the
counter for numRecordsOutPerSecond metric explicity in our codes? As this
metric is automatically exposed to prometheus for every txns that goes in
to asyncInvoke() of our RichAsyncFunction every single second?
I tr
Hi,
What's your question?
Best
Ron
patricia lee 于2023年9月7日周四 14:29写道：
> Hi flink users,
>
> I used Async IO (RichAsyncFunction) for sending 100 txns to a 3rd party.
>
> I check the runtimeContex that it has metric of numRecordsSent, we wanted
> to expose this metric to our prometheus server so
Hi flink users,
I used Async IO (RichAsyncFunction) for sending 100 txns to a 3rd party.
I check the runtimeContex that it has metric of numRecordsSent, we wanted
to expose this metric to our prometheus server so that we can monitor how
much records we are sending per second. The reason why we ne
