Hi Daniel,
This is currently a limitation in Flink's savepoints. You can not change
the serialization schema of the state between savepoints.
In Flink 1.2 there might be the first building blocks available for using
serializers aware of savepoints.
Exposing this feature to the API will probably ta
Hello,
Is it possible to change the object that is being serialized or
deserialized?
Let's say we have something like the following :
stream
.window()
.fold(InitialValueA)(FoldFunction)
Now, InitialValueA is a case class A(n1 : Int).
Restoring the same job from a savepoint but wi
