flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Daniel Santos <dsan...@cryptolab.net>
Subject State Serializer/Deserializer between savepoints
Date Wed, 23 Nov 2016 18:16:42 GMT

Is it possible to change the object that is being serialized or 

Let's say we have something like the following :




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

View raw message