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)
