??????RE: how to get flink accumulated sink record count

[Enric Ott]

Thanks,Jiabao,but what I mean is capturing the metric in Flink tasks.




------------------ ???????? ------------------
??????: "Jiabao Sun"<jiabao....@xtransfer.cn&gt;; 
????????: 2024??1??25??(??????) ????3:11
??????: "user"<user@flink.apache.org&gt;; 
????: RE: how to get flink accumulated sink record count





I guess getting the metrics[1] might be helpful for you. 
You can query the numRecordsOut metric by Metrics Reporter[2] or REST API[3].

Best,
Jiabao

[1] https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/ops/metrics/
[2] 
https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/deployment/metric_reporters/
[2] 
https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/ops/rest_api/#jobs-metrics

On 2024/01/25 06:54:36 Enric Ott wrote:
&gt; Hi??Team??
&gt; I was wondering how to get flink accumulated sink record count(just like 
the flink UI displays),any help would be appreciated.