Hi Team, Earlier we have developed on flink 1.6.2 , So there are lots of case classes which have Map,Nested case class within them for example below :
case class MyCaseClass(var a: Boolean, var b: Boolean, var c: Boolean, var d: NestedCaseClass, var e:Int){ def this(){this(false,false,new NestedCaseClass,0)} } Now we have migrated to flink 1.8.2 , I need help to figure out how can I achieve state schema evolution for such classes. 1. Is creating avro for these classes now, and implement avro serialisation will that work ? 2. Or if I register kyroserialiser with protobuf serialiser at env? Please suggest what can be done here, or redirect for the avros serialisation example. Thanks -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/