Hi All,
We are trying to restore a job using relocated savepoint
files. As pointed out in the FAQs of savepoint documentation, savepoints
have absolute paths recorded in them and hence a simple relocation to
restore the job would fail. As directed in the documentation we tried out
the simple way to refactor the paths by editing them manually, but the job
submission failed with an IllegalStateException as noted below :
Caused by: java.lang.IllegalStateException: Reading invalid
OperatorStateHandle, type: 50
at
org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer.deserializeOperatorStateHandle(SavepointV2Serializer.java:499)
We then went ahead and gave a swing at the second prescribed option of
utilizing the SavepointV2Serializer for deserializing and serializing the
metadata file. Even with this approach we observed that the generated
metadata file still referenced the old absolute path. We are in a stuck in a
predicament as of now. How is it that we can set / change the absolute paths
present in the metadata file using the prescribed SavepointV2Serializer.
It’d be helpful if you could provide some insight into this.
Thanks,
Parth Sarathy
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
