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

Ufuk Celebi closed FLINK-3250.
------------------------------
    Resolution: Fixed

a5bba3c

> Savepoint coordinator requires too strict parallelism match
> -----------------------------------------------------------
>
>                 Key: FLINK-3250
>                 URL: https://issues.apache.org/jira/browse/FLINK-3250
>             Project: Flink
>          Issue Type: Bug
>          Components: Distributed Runtime
>            Reporter: Ufuk Celebi
>            Assignee: Ufuk Celebi
>             Fix For: 1.0.0
>
>
> The savepoint coordinator requires that the number of collected states of an 
> operator and the parallelism of the new job (the one to be restored) match 
> exactly. This is too strict.
> For example a Kafka source with parallelism 2 and a single Kafka partition 
> does not collect state for one of the two sources (hence it is not part of 
> the savepoint state). Currently, restoring the same job with the same 
> parallelism fails, which should not happen.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to