OH SEUNG CHEOL created FLINK-13117:
--------------------------------------
Summary: Serialize Issue when restoring from savepoint
Key: FLINK-13117
URL:
https://issues.apache.org/jira/browse/FLINK-13117 Project: Flink
Issue Type: Bug
Reporter: OH SEUNG CHEOL
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.3#76005)
Locked
