Weijie Guo created FLINK-32621:
----------------------------------
Summary: Add metrics for DataGeneratorSource
Key: FLINK-32621
URL: https://issues.apache.org/jira/browse/FLINK-32621
Project: Flink
Issue Type: Technical Debt
Affects Versions: 1.18.0
Reporter: Weijie Guo
Assignee: Weijie Guo
{{DataGeneratorSource}} use {{GeneratingIteratorSourceReader}} instead of
{{SourceReaderBase}} as sourceReader. So it lacks metrics like numRecordIn
contains by SourceReaderBase.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
