Hi, Could you share the detailed exception stack ? Or Did you modify any job logic or parameters ? Currently, Flink only supports simple schema evolution (e.g. add or remove fields for pojo types) for DataStream Jobs[1]. Other modifications may cause this exception, for example: 1. modify some schemas for SQL Jobs 2. some complex modifications for DataStream Jobs (e.g. modify schema of kryo types) 3. modify some parameters (e.g. enable TTL or disable TTL[2])
[1] https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/datastream/fault-tolerance/serialization/schema_evolution/ [2] https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/datastream/fault-tolerance/state/#state-time-to-live-ttl On Mon, Jul 3, 2023 at 7:56 PM 湘晗刚 <1016465...@qq.com> wrote: > > Hi team : restore.from savepoint i meet: > the new state serializer can not be incompatible > > Who can help me? > > Thanks in advance > Kobe24 > -- Best, Hangxiang.
