Jing Ge created FLINK-28117:
-------------------------------
Summary: More metrics for FileSource
Key: FLINK-28117
URL: https://issues.apache.org/jira/browse/FLINK-28117
Project: Flink
Issue Type: Improvement
Reporter: Jing Ge
According to user's requirement[1], following metrics are required:
1. No. of splits SplitAssigner is initialized with, number of splits re-added
back to the SplitAssigner
2. Readers created per unit time
3. Time taken to create a reader
4. Time taken for the Reader to produce a single Row
5. Readers closed per unit time
Some further nice-to-have metrics:1. Number of rows emitted by the source per
unit time
2. Time taken by the enumerator to discover the splits
3. Total splits discovered
Please check FLIP-33 first and extend it if above mentioned metrics were not
included in the FLIP.
[1] https://lists.apache.org/thread/t70hhss6d9s65y1vygyytbm6sgl05yrl
--
This message was sent by Atlassian Jira
(v8.20.7#820007)