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
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


Mime
View raw message