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)