Hi Qinghui, Did you used a difference keyby() for your KeyedCoProcesserOperator? For example, did you use a fied name (keyBy(“id”)) in 1.9 and while use a lambda (keyBy(e->e.getId()) in 1.13. This will make the key serializer incompatible.
You may reference this link for how to use Apache Flink’s State Processor API to modifying savepoints: https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/libs/state_processor_api/ > On 14 Apr 2022, at 1:44 AM, XU Qinghui <qinghui...@gmail.com> wrote: > > The new key serializer > (org.apache.flink.api.java.typeutils.runtime.RowSerializer@896510d) must be > compatible with the previous key serializer
