Danny Cranmer created FLINK-25846:
-------------------------------------
Summary: Async Sink does not gracefully shutdown on Cancel
Key: FLINK-25846
URL: https://issues.apache.org/jira/browse/FLINK-25846
Project: Flink
Issue Type: Sub-task
Reporter: Danny Cranmer
h4. Description
Async Sink does not react gracefully to cancellation signal
h4. Reproduction Steps
- Start a job using an Async Sink implementation, for example KDS
- Navigate to Flink Dashboard
- Click Job > Cancel
h4. Actual Results
- Sink operator stuck in Cancelling, retrying
h4. Expected Results
- Sink operator closes
h4. Suggested Resolution
- Async Sink should treat `InterruptedException` as stop signal
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
