Hi to all, we've just upgraded to Flink 1.0.0 and we had some problems with joda DateTime serialization. The problem was caused by Flink-3305 that removed the JavaKaffee dependency. We had to re-add such dependency in our application and then register the DateTime serializer in the environment:
env.registerTypeWithKryoSerializer(DateTime.class, JodaDateTimeSerializer.class ); and in the pom.xml of course (checking compatibility with Flink's Kryo version that is 2.24.0): <dependency> <groupId>de.javakaffee</groupId> <artifactId>kryo-serializers</artifactId> <version>0.28</version> </dependency> We didn't see a mention to this problem in the migration guide, I think it should be added. Best, Stefano