Hi Elias,
I think introducing a new state and the deprecating the old one is
currently the only way to solve this problem.
The community is currently working on supporting state evolution [1]. With
this feature it should be possible to change serializers between two
savepoints. Unfortunately,
Apologies for the delay. I've been traveling.
On Mon, Jul 9, 2018 at 8:44 AM Till Rohrmann wrote:
> could you check whether the `TypeInformation` returned by
> `TypeInformation.of(new TypeHint[ConfigState]() {}))` and
> `createTypeInformation[ConfigState]` return the same `TypeInformation`
>
Hi Elias,
could you check whether the `TypeInformation` returned by
`TypeInformation.of(new TypeHint[ConfigState]() {}))` and
`createTypeInformation[ConfigState]` return the same `TypeInformation`
subtype? The problem is that the former goes through the Java TypeExtractor
whereas the latter goes
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
