Hi Kamal, Can you give more information about the metris you want? In Flink each source task has one source reader which already has some metrics, you can refer to metrics doc[1] for more detailed information.
[1] https://nightlies.apache.org/flink/flink-docs-master/docs/ops/metrics/ Best, Shammon FY On Tue, Jun 13, 2023 at 11:13 AM Kamal Mittal via user < user@flink.apache.org> wrote: > Hello, > > > > Using Flink record stream format file source API as below for parquet > records reading. > > > > FileSource.FileSourceBuilder<?> source = FileSource. > *forRecordStreamFormat*(streamformat, path); > > source.monitorContinuously(Duration.*ofMillis*(10000)); > > > > Want to log/generate metrices for corrupt records and for the same need to > log flink metrices at *source level* in parquet reader class, is there > any way to do that as right now no handle for SourceContext available? > > > > Rgds, > > Kamal >
