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/
