Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-4808 Allow skipping failed checkpoints
  3. FLINK-4809

Operators should tolerate checkpoint failures

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Closed
    • Major
    • Resolution: Fixed
    • None
    • 1.5.0
    • Runtime / State Backends
    • None

    Description

      Operators should try/catch exceptions in the synchronous and asynchronous part of the checkpoint and send a DeclineCheckpoint message as a result.

      The decline message should have the failure cause attached to it.

      The checkpoint barrier should be sent anyways as a first step before attempting to make a state checkpoint, to make sure that downstream operators do not block in alignment.

      Attachments

        Issue Links

          blocks

          Sub-task - The sub-task of the issue FLINK-4811 Checkpoint Overview should list failed checkpoints

          • Major - Major loss of function.
          • Open
          causes

          Bug - A problem which impairs or prevents the functions of the product. FLINK-17350 StreamTask should always fail immediately on failures in synchronous part of a checkpoint

          • Critical - Crashes, loss of data, severe memory leak.
          • Closed
          links to

          Web Link GitHub Pull Request #4883

          Activity

            People

              srichter Stefan Richter
              sewen Stephan Ewen
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: