State Serializer/Deserializer between savepoints

[Daniel Santos]

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(<SomeWindow>)

    .fold(InitialValueA)(FoldFunction)


Now, InitialValueA is a case class A(n1 : Int).

Restoring the same job from a savepoint but with a slightly diferent 
initial value - InitialValueA case class A(n1 : Int, n2 : Int).

Will result in an error.

Is it possible to change the initial value, between savepoints ?

Maybe implementing a different/custom serializer for classA ?


Best Regards,

Daniel Santos