Hi! The exception that you have bumped into indicates that on the restore of the savepoint, the serializer for that registered state in the savepoint no longer exists. This prevents restoring savepoints taken with memory state backends because there will be no serializer available to deserialize the state at restore time.
My current guess of what is happening is that the generated serializers for case class B1 has different generated names, and therefore in your modified repackaged job, it would be as if the previous serializer no longer exists in the classpath. The serializer generation for Scala case classes (the `createTypeInformation[B1]` call) depends on some Scala macros, and the resulting generated anonymous class is sensitive to quite a few factors. Could you perhaps try to verify this by checking the classname of the generated serializers (you can get the serializer by `createTypeInformation[B1].getSerializer(new Configuration())`)? If they are different for the same case class across 2 different compilations of your job (one with the B2 case class, one without), then my assumption is correct. Otherwise, we would of course need to look deeper. I'll also think about how to probably best workaround that for now meanwhile and get back to you .. Cheers, Gordon -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
