[ 
https://issues.apache.org/jira/browse/FLINK-6742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027496#comment-16027496
 ] 

Chesnay Schepler commented on FLINK-6742:
-----------------------------------------

Why is the state incompatible? Is this tied to upgrading Flink or a change in 
the user code?

At the moment i can only think of the following workarounds:

1. Remove the operators from the topology and load them in 1.2 while allowing 
non-restored State. Take a new savepoint, add your operators, load in 1.3.
2. Add 2 no-op operators to the topology and assign them the UID's of the 
operators you want to drop. Load 1.2 savepoint, create 1.3 SP, drop operators, 
reload.

> Savepoint conversion might fail if operators change
> ---------------------------------------------------
>
>                 Key: FLINK-6742
>                 URL: https://issues.apache.org/jira/browse/FLINK-6742
>             Project: Flink
>          Issue Type: Bug
>          Components: State Backends, Checkpointing
>    Affects Versions: 1.3.0
>            Reporter: Gyula Fora
>            Priority: Critical
>
> Caused by: java.lang.NullPointerException
>       at 
> org.apache.flink.runtime.checkpoint.savepoint.SavepointV2.convertToOperatorStateSavepointV2(SavepointV2.java:171)
>       at 
> org.apache.flink.runtime.checkpoint.savepoint.SavepointLoader.loadAndValidateSavepoint(SavepointLoader.java:75)
>       at 
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator.restoreSavepoint(CheckpointCoordinator.java:1090)



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to