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

Posted to issues@flink.apache.org by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/03/10 08:55:00 UTC

[jira] [Assigned] (FLINK-26445) Unified Sink cannot restore committer state

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

Fabian Paul reassigned FLINK-26445:
-----------------------------------

    Assignee: Fabian Paul

> Unified Sink cannot restore committer state
> -------------------------------------------
>
>                 Key: FLINK-26445
>                 URL: https://issues.apache.org/jira/browse/FLINK-26445
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / Common
>    Affects Versions: 1.14.3
>            Reporter: Fabian Paul
>            Assignee: Fabian Paul
>            Priority: Critical
>
> In Flink 1.14 the writer and committer operator became one operator in streaming mode. Unfortunately, the state is still associated with the previous physical operator so during restore the job fails due non-restored state of the committer operator.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)