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

BoundedOneInput.endInput is NOT called when doing stop with savepoint WITH drain

    XMLWordPrintableJSON

Details

    Description

      In FLINK-21132 we disable endInput calls when stopping with savepoint. However as discussed in FLINK-21133, stop with savepoint with drain (stop-with-savepoint --drain), should be calling endOfInput().

      Attachments

        Issue Links

          is caused by

          Bug - A problem which impairs or prevents the functions of the product. FLINK-21132 BoundedOneInput.endInput is called when taking synchronous savepoint

          • Major - Major loss of function.
          • Closed
          relates to

          Bug - A problem which impairs or prevents the functions of the product. FLINK-21133 FLIP-27 Source does not work with synchronous savepoint

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

          Web Link GitHub Pull Request #15000

          Web Link GitHub Pull Request #15007

          Web Link GitHub Pull Request #15011

          Web Link GitHub Pull Request #15012

          Activity

            People

              pnowojski Piotr Nowojski
              pnowojski Piotr Nowojski
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: