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

stop-with-savepoint can fail with FlinkKinesisConsumer

    XMLWordPrintableJSON

Details

    Description

      FlinkKinesisConsumer#cancel() (inside KinesisDataFetcher#shutdownFetcher()) shouldn't be interrupting source thread. Otherwise, as described in FLINK-23527, network stack can be left in an invalid state and downstream tasks can encounter deserialisation errors.

      Attachments

        Issue Links

          Activity

            People

              kdziolak Krzysztof Dziolak
              pnowojski Piotr Nowojski
              Votes:
              1 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: