You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/03/02 07:54:00 UTC

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

Fabian Paul created FLINK-26445:
-----------------------------------

             Summary: 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


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)