Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-23883 (1.15) Follow up tasks and code improvements for FLIP-147
  3. FLINK-23532

Unify stop-with-savepoint w drain and w/o drain

    XMLWordPrintableJSON

Details

    Description

      The code paths for stop-with-savepoint --drain and w/o drain are different after FLINK-23408. We should unify the two and in both cases we should wait for the savepoint in afterInvoke and close sources before triggering the last checkpoint.

      Attachments

        Issue Links

          causes

          Bug - A problem which impairs or prevents the functions of the product. FLINK-28758 FlinkKafkaConsumer fails to stop with savepoint

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

          Bug - A problem which impairs or prevents the functions of the product. FLINK-24161 Can not stop the job with savepoint while a task is finishing

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

          Web Link GitHub Pull Request #17968

          Activity

            People

              dwysakowicz Dawid Wysakowicz
              dwysakowicz Dawid Wysakowicz
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: