Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-28117

More metrics for FileSource

    XMLWordPrintableJSON

Details

    Description

      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

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              jingge Jing Ge
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated: