public class JavaSerializer<T>
This is a reimplementation of Kryo's JavaSerializer,
that additionally makes sure the ObjectInputStream used for deserialization specifically uses Kryo's
Flink maintains this reimplementation due to a known issue with Kryo's JavaSerializer, in which the wrong
classloader may be used for deserialization, leading to ClassNotFoundExceptions.