Re: StateMigrationException thrown by state processor api

2019-08-27 Thread Paul Lam
Tang > From: Paul Lam > Sent: Tuesday, August 27, 2019 17:14 > To: user > Cc: Tzu-Li (Gordon) Tai > Subject: StateMigrationException thrown by state processor api > > Hi, > > I was using the new state processor api to read a savepoint produced by Flink > 1.5.

Re: StateMigrationException thrown by state processor api

2019-08-27 Thread Yun Tang
space serializer. Best Yun Tang From: Paul Lam Sent: Tuesday, August 27, 2019 17:14 To: user Cc: Tzu-Li (Gordon) Tai Subject: StateMigrationException thrown by state processor api Hi, I was using the new state processor api to read a savepoint produced

StateMigrationException thrown by state processor api

2019-08-27 Thread Paul Lam
Hi, I was using the new state processor api to read a savepoint produced by Flink 1.5.3, and got an StateMigrationException with message “For heap backends, the new namespace serializer must be compatible”. Concretely, the state I was trying to read is a MapState within a