Recovering snapshot state saved with TypeInformation generated by the implicit macro from the scala API

2018-04-10 Thread Petter Arvidsson
Hello everyone, We are trying to recover state from a snapshot which we can no longer load. When it is loaded we receive the following exception: java.lang.ClassNotFoundException: io.relayr.counter.FttCounter$$ anon$71$$anon$33 This, via a couple more exceptions, leads to: java.io.IOException:

Re: Managing state migrations with Flink and Avro

2018-04-18 Thread Petter Arvidsson
ema? > > Thank you. > > Regards, > Timo > > Am 18.04.18 um 11:00 schrieb Petter Arvidsson: > > Hello everyone, > > I am trying to figure out how to set up Flink with Avro for state > management (especially the content of snapshots) to enable state migrations > (e.g. addin

Managing state migrations with Flink and Avro

2018-04-18 Thread Petter Arvidsson
Hello everyone, I am trying to figure out how to set up Flink with Avro for state management (especially the content of snapshots) to enable state migrations (e.g. adding a nullable fields to a class). So far, in version 1.4.2, I tried to explicitly provide an instance of "new

Re: Managing state migrations with Flink and Avro

2018-04-23 Thread Petter Arvidsson
the issue (see > https://issues.apache.org/jira/browse/FLINK-9202). I will use your code > to verify it. > > Regards, > Timo > > > Am 18.04.18 um 14:07 schrieb Petter Arvidsson: > > Hi Timo, > > Please find the generated class (for the second schema) attached. &g