Hi, Thanks for reporting this.
Could you provide more details (error message, exception stack trace) that you are getting? This is unexpected, as the changes to flink-avro serializers in 1.7.x should be backwards compatible. More details on how the restore failed will be helpful here. Cheers, Gordon On Wed, Jan 23, 2019 at 2:54 PM pwestermann <no.westerm...@genesys.com> wrote: > I am trying to migrate from Flink 1.6.3 to 1.7.1 but am not able to restore > the job from a savepoint taken in 1.6.3. > > We are using an AsyncFunction to publish Avro records to SQS. The state for > the AsyncWaitOperator cannot be restored because of serializer changes in > flink-avro from 1.6.3 to 1.7.1. > > Any idea how to avoid this problem? Maybe start the job with flink-avro > 1.6.3 or will that break other parts? > > Thanks, > Peter > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
