Hi, Kirti Dhar Upadhyay K. We could get the metric group from the context, like `SourceReaderContext` and `SplitEnumeratorContext`. These contexts could be found when creating readers and enumerators. See `AbstractFileSource#createReader` and `AbstractFileSource#createEnumerator`.
Best, Hang Kirti Dhar Upadhyay K via user <user@flink.apache.org> 于2023年6月5日周一 22:57写道： > Hi Community, > > > > I am trying to add a new counter for number of files collected on Flink > File Source. > > Referring the doc > https://nightlies.apache.org/flink/flink-docs-master/docs/ops/metrics/ I > understand how to add a new counter on any operator. > > > > *this.*counter *=* *getRuntimeContext().*getMetricGroup*().*counter*(* > "myCounter"*);* > > > > But not able to get this RuntimeContext on FileSource. > > Can someone give some clue on this? > > > > Regards, > > Kirti Dhar >
