Hello, I can't seem to be able to override the CaseClassSerializer with my custom serializer. I'm using env.getConfig.addDefaultKryoSerializer() to add the custom serializer but I don't see it being used. I guess it is because it only uses Kryo based serializers if it can't find a Flink serializer?
Is then worth it to replace the CaseClassSerializer with a custom serializer? (when I profile the CaseClassSerializer.(de)serialize method appears as the most used so I wanted to give it a try) If so, how can I do it? Thanks, Gerard -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
