[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Scala case class state evolution

Hi Elias,

From my understanding, you can't do this since the state will no longer be compatible.

Best, Hequn

On Wed, Oct 3, 2018 at 6:32 AM Elias Levy <fearsome.lucidity@xxxxxxxxx> wrote:
Currently it is impossible to evolve a Scala case class by adding a new field to it that is stored as managed state using the default Flink serializer and restore a the job from a savepoint created using the previous version of the class, correct?