[
https://issues.apache.org/jira/browse/FLINK-32621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-32621:
-------------------------------
Description: {{DataGeneratorSource}} use {{GeneratingIteratorSourceReader}}
instead of {{SourceReaderBase}} as sourceReader. So it lacks metrics like
numRecordIn contained by SourceReaderBase. (was: {{DataGeneratorSource}} use
{{GeneratingIteratorSourceReader}} instead of {{SourceReaderBase}} as
sourceReader. So it lacks metrics like numRecordIn contains by
SourceReaderBase.)
> 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
> Priority: Major
>
> {{DataGeneratorSource}} use {{GeneratingIteratorSourceReader}} instead of
> {{SourceReaderBase}} as sourceReader. So it lacks metrics like numRecordIn
> contained by SourceReaderBase.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
