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

Test the ability for ignoring in-flight data on recovery

    XMLWordPrintableJSON

Details

    Description

      Test for  https://issues.apache.org/jira/browse/FLINK-22684:

      1. configure the external checkpoint address (storage)
      2. enable unaligned checkpoint always (not the default aligned or alternative)
      3. wait for the checkpoint then stop the job
      4. restore from the last checkpoint - it should be restored on the last state(optional step)
      5. set the `execution.checkpointing.recover-without-channel-state.checkpoint-id` to the last checkpoint
      6. restore from the last checkpoint - in-flight data would be ignored so it would be restored a little less data than expected in the usual case.

       

      Attachments

        Activity

          People

            Unassigned Unassigned
            akalashnikov Anton Kalashnikov
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: