Hi, Could you confirm that you’re using POJOSerializer before and after migration?
Best, Paul Lam > 在 2019年10月17日，21:34，ApoorvK <apoorv.upadh...@razorpay.com> 写道： > > It is throwing below error , > the class I am adding variables have other variable as an object of class > which are also in state. > > Caused by: org.apache.flink.util.StateMigrationException: The new state > typeSerializer for operator state must not be incompatible. > at > org.apache.flink.runtime.state.DefaultOperatorStateBackend.getListState(DefaultOperatorStateBackend.java:323) > at > org.apache.flink.runtime.state.DefaultOperatorStateBackend.getListState(DefaultOperatorStateBackend.java:214) > at > org.apache.flink.streaming.api.operators.async.AsyncWaitOperator.initializeState(AsyncWaitOperator.java:268) > at > org.apache.flink.streaming.api.operators.AbstractStreamOperator.initializeState(AbstractStreamOperator.java:278) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.initializeState(StreamTask.java:740) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:291) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711) > at java.lang.Thread.run(Thread.java:748) > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
