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 external 3rd party. Regards, P On Thu, Sep 7, 2023, 9:38 PM patricia lee <plee3...@gmail.com> wrote: > 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 tried to check this metric in our code but the it doesn't increment. > > > Regards, > Pat > > On Thu, Sep 7, 2023, 7:08 PM liu ron <ron9....@gmail.com> wrote: > >> Hi, >> >> What's your question? >> >> Best >> Ron >> >> patricia lee <plee3...@gmail.com> 于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 that we can >>> monitor how much records we are sending per second. The reason why we need >>> to monitor, is because there is additional cost for every additional txn >>> exceeding the allowed tps for us to send. >>> >>> >>> Any input would be appreciated. >>> >>> >>> Regards, >>> Patricia >>> >>> >>> >>> >>>
