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

Posted to issues@flink.apache.org by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/01/27 09:19:00 UTC

[jira] [Updated] (FLINK-25846) [FLIP-171] Async Sink does not gracefully shutdown on Cancel

     [ https://issues.apache.org/jira/browse/FLINK-25846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Danny Cranmer updated FLINK-25846:
----------------------------------
    Summary: [FLIP-171] Async Sink does not gracefully shutdown on Cancel  (was: Async Sink does not gracefully shutdown on Cancel)

> [FLIP-171] 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
>          Components: Connectors / Common
>            Reporter: Danny Cranmer
>            Assignee: Zichen Liu
>            Priority: Major
>             Fix For: 1.15.0
>
>
> 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)