Qingsheng Ren created FLINK-30234:
-------------------------------------
Summary: SourceReaderBase should provide an option to disable
numRecordsIn metric registration
Key: FLINK-30234
URL: https://issues.apache.org/jira/browse/FLINK-30234
Project: Flink
Issue Type: Improvement
Components: Connectors / Common
Affects Versions: 1.17.0
Reporter: Qingsheng Ren
Currently the numRecordsIn metric is pre-registered for all sources in
SourceReaderBase. Considering different implementation of source reader, the
definition of "record" might differ from the one we use in SourceReaderBase,
hence numRecordsIn might be inaccurate.
We could introduce an option in SourceReader to disable the registration of
numRecordsIn in SourceReaderBase and let the actual implementation to report
the metric instead.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
