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)

Reply via email to