Thanks. Can you please also let me know that why for source like '0.Source__RandomNumberSource.numRecordsIn' is always seen as '0' and only out records count is shown?
Similarly for sink like '0.Sink__Print_to_Std__Out.numRecordsOut' is always shown as '0' and only in records count is shown? Rgds, Kamal From: Andreas Bube <ab...@toogoodtogo.com> Sent: 21 May 2025 11:41 To: Kamal Mittal <kamal.mit...@ericsson.com> Subject: Re: Flink metrices for pending records You don't often get email from ab...@toogoodtogo.com<mailto:ab...@toogoodtogo.com>. Learn why this is important<https://aka.ms/LearnAboutSenderIdentification> Hi Kamal, Each Source implementation may provide it's own set of metrics. Kafka, for instance, has a "pendingRecords" metrics. See https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/ops/metrics/ On Wed, 21 May 2025 at 06:39, Kamal Mittal via user <user@flink.apache.org<mailto:user@flink.apache.org>> wrote: Hello, Can you please help to know if any metrices for "pending records" at source level is exposed by flink - 1.20? At below link there is nothing like that. Metrics | Apache Flink<https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/ops/metrics/> Rgds, Kamal
