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 <[email protected]> Sent: 21 May 2025 11:41 To: Kamal Mittal <[email protected]> Subject: Re: Flink metrices for pending records You don't often get email from [email protected]<mailto:[email protected]>. 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 <[email protected]<mailto:[email protected]>> 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
