Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-25842 [v2] FLIP-158: Generalized incremental checkpoints
  3. FLINK-25470

Add/Expose/Differentiate metrics of checkpoint size between changelog size vs materialization size

    XMLWordPrintableJSON

Details

    Description

      FLINK-25557  only resolves part of the problems. 

      Eventually, we should answer questions:

      • How much Data Size increases/exploding
      • When a checkpoint includes a new Materialization
      • Materialization size
      • changelog sizes from the last complete checkpoint (that can roughly infer restore time)

       

       

      Attachments

        Issue Links

          Activity

            People

              masteryhx Hangxiang Yu
              ym Yuan Mei
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: