Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-32726 [Umbrella] Test Flink Release 1.18
  3. FLINK-32911

Release Testing: Verify FLINK-28386: Trigger an immediate checkpoint after all sinks finished

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 1.18.0
    • 1.18.0
    • Tests
    • None

    Description

      The feature is described in the doc .

      To test the feature, we should run a Flink program on a bounded source and configure it with a large checkpoint interval. With this feature, the program should end up immediately when no more records need to be processed, instead of waiting for one more periodic checkpoint.

      Attachments

        1. data.txt.gz
          7.91 MB
          Matthias Pohl
        2. flink-1.17.1.log
          141 kB
          Matthias Pohl
        3. flink-1.18-6e4c2d1-SNAPSHOT.log
          149 kB
          Matthias Pohl

        Issue Links

          is caused by

          Sub-task - The sub-task of the issue FLINK-28386 Trigger an immediate checkpoint after all tasks has reached end-of-data

          • Major - Major loss of function.
          • Closed
          Testing discovered

          Bug - A problem which impairs or prevents the functions of the product. FLINK-32945 NullPointerException when executing TopSpeedWindowing example with checkpointing enabled

          • Blocker - Blocks development and/or testing work, production could not run
          • Closed

          Activity

            People

              mapohl Matthias Pohl
              Jiang Xin Jiang Xin
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: