[
https://issues.apache.org/jira/browse/FLINK-13117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13117:
-----------------------------------
Labels: pull-request-available (was: )
> Serialize Issue when restoring from savepoint
> ---------------------------------------------
>
> Key: FLINK-13117
> URL: https://issues.apache.org/jira/browse/FLINK-13117
> Project: Flink
> Issue Type: Bug
> Reporter: dmgkeke
> Priority: Major
> Labels: pull-request-available
>
> Hi, I have one question.
> My application should be maintained without loss of data.
> So I use savepoint to deploy a new application.
>
> Normally there is no problem in restarting.
> However, when the schema of some case classes is changed, a serialize error
> occurs at restart.
>
> How can I resolve this?
> Flink version is 1.8.0
> Here is the error log.
> Thank you.
> ----
> org.apache.flink.util.StateMigrationException: The new state serializer
> cannot be incompatible.
> at
> org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.updateRestoredStateMetaInfo(RocksDBKeyedStateBackend.java:527)
> at
> org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.tryRegisterKvStateInformation(RocksDBKeyedStateBackend.java:475)
> at
> org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.createInternalState(RocksDBKeyedStateBackend.java:613)
> at
> org.apache.flink.runtime.state.KeyedStateFactory.createInternalState(KeyedStateFactory.java:47)
> at
> org.apache.flink.runtime.state.ttl.TtlStateFactory.createStateAndWrapWithTtlIfEnabled(TtlStateFactory.java:72)
> at
> org.apache.flink.runtime.state.AbstractKeyedStateBackend.getOrCreateKeyedState(AbstractKeyedStateBackend.java:286)
> at
> org.apache.flink.streaming.api.operators.AbstractStreamOperator.getOrCreateKeyedState(AbstractStreamOperator.java:568)
> at
> org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.open(WindowOperator.java:240)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:424)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:290)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)
> at java.lang.Thread.run(Thread.java:748)
> ----
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
