You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/07/29 06:36:00 UTC

[jira] [Created] (FLINK-23538) FlinkKinesisConsumer should not interrupt the legacy source thread in cancel

Dawid Wysakowicz created FLINK-23538:
----------------------------------------

             Summary: FlinkKinesisConsumer should not interrupt the legacy source thread in cancel
                 Key: FLINK-23538
                 URL: https://issues.apache.org/jira/browse/FLINK-23538
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kinesis
            Reporter: Dawid Wysakowicz
             Fix For: 1.14.0


We use {{SourceFunction#cancel()}} not just to forcefully cancel the source thread, but also to gracefully stop the legacy source function in order to perform e.g. the {{stop-with-savepoint}}. Therefore we want to clarify the contract of {{cancel()}} and force it to be a graceful cancel.

Currently the FlinkKinesisConsumer is the only known source that does not perform a graceful stop there, but instead it interrupts the legacy source thread.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)