Re: [External] Re: Way to add columns with defaults to the existing table and recover from the savepoint

2023-03-28 Thread Martijn Visser
You could consider trying out the experimental version upgrade that was introduced as part of FLIP-190: https://cwiki.apache.org/confluence/x/KZBnCw On Tue, Mar 21, 2023 at 12:11 PM Ashish Khatkar via user < user@flink.apache.org> wrote: > Hi Shammon, > > Schema evolution works with avro type

Re: [External] Re: Way to add columns with defaults to the existing table and recover from the savepoint

2023-03-21 Thread Ashish Khatkar via user
Hi Shammon, Schema evolution works with avro type state, and Flink Table API uses RowData and has a serializer (RowDataSerializer) for it which doesn't allow change in column structure. Regarding state processor api, we are not creating any state in our service, we simply use Flink sql as a