Hello,

java.lang.Object is serialized by Kryo as it is taken as generic data type by 
Flink.

Is there any way to switch it to some other serializer for performance 
improvement or not? Also can you please give some documentation for reference 
around it?

I profiled my application and then found that Kryo is being used, I tried to 
disable it by disableGenericTypes() and application breaks at start-up with 
error "Object type treated as generic type".

Rgds,
Kamal

Reply via email to