Flink bulk and record file source format metrices

[Kamal Mittal via user]

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