Hi Roman,
I have successfully migrated to flink 1.8.2 with the savepoint created by
flink 1.6.2.
Now I have to modify few case classes due to new requirement I have created
a savepoint and when I run the app with modified class from the savepoint
it throws error "state not compatible"
Previously there were no serializer used.
I now wish to support state schema Hence need suggestion how can i achieve
that ?
Regards
On Tue, Feb 25, 2020 at 9:08 PM Khachatryan Roman <
khachatryan.ro...@gmail.com> wrote:
> Hi ApoorvK,
>
> I understand that you have a savepoint created by Flink 1.6.2 and you want
> to use it with Flink 1.8.2. The classes themselves weren't modified.
> Is that correct?
> Which serializer did you use?
>
> Regards,
> Roman
>
>
> On Tue, Feb 25, 2020 at 8:38 AM ApoorvK <apoorv.upadh...@razorpay.com>
> wrote:
>
>> 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/
>>
>
