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