StateMigrationException when switching from TypeInformation.of to createTypeInformation

Posted by Elias Levy on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/StateMigrationException-when-switching-from-TypeInformation-of-to-createTypeInformation-tp21276.html

During some refactoring we changed a job using managed state from:

ListStateDescriptor("config", TypeInformation.of(new TypeHint[ConfigState]() {}))

to

ListStateDescriptor("config", createTypeInformation[ConfigState])

After this change, Flink refused to start the new job from a savepoint or checkpoint, raising StateMigrationException instead.

Why is Flink raising this error?  Both TypeInformation.of and createTypeInformation return TypeInformation[ConfigState], so why does it think the state type has changed?