Re: stateSerializer(1.14.0) not compatible with previous stateSerializer(1.13.1)

2021-12-15 Thread 李诗君
Hi, Im using Flink-SQL, so maybe it is the default kryo serializer. > 2021年12月10日 下午4:15,Roman Khachatryan 写道: > > Hi, > > Compatibility might depend on specific serializers, > could you please share which serializers you use to access the state? > > Regards, > Roman > > On Fri, Dec 10, 2021

Re: stateSerializer(1.14.0) not compatible with previous stateSerializer(1.13.1)

2021-12-10 Thread Roman Khachatryan
Hi, Compatibility might depend on specific serializers, could you please share which serializers you use to access the state? Regards, Roman On Fri, Dec 10, 2021 at 3:41 AM 李诗君 wrote: > > I am trying to upgrade my flink cluster version from 1.13.1 to 1.14.0 , I did > like below steps: > > 1. s

stateSerializer(1.14.0) not compatible with previous stateSerializer(1.13.1)

2021-12-09 Thread 李诗君
I am trying to upgrade my flink cluster version from 1.13.1 to 1.14.0 , I did like below steps: 1. savepoint running tasks in version1.13.1 2. stop tasks and upgrade cluster version to 1.14.0 3. recover tasks with savepoints and this happened: java.lang.RuntimeException: Error while getting st