Just using a copy of AvroSerializer with the serialVersionUID set to 1 did not work. There was a NullPointerException on the next checkpoint, probably because previousSchema doesn't exist in the old serializer.
However, the version from the PR with serialVersionUID set to 1 worked. (I didn't want to have to change classes in flink-core, that's why I just changed the serialVersionUID). Thanks again Gordon! Peter -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
