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