Hi Enric, 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: > Hi,Team: > I was wondering how to get flink accumulated sink record count(just like the > flink UI displays),any help would be appreciated.