Hello,
I've had good luck implementing `Value` to have Flink (1.19, not sure
about earlier versions) use my custom serialization code for a
particular type. More details in the docs here:
https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/dev/datastream/fault-tolerance/serializati
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
