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/serialization/types_serialization/#values
If you're stuck pushing around `java.lang.Object`, you can still wrap it
in another type that implements `Value`.
Best,
Kirill
On 11/8/24 12:01 AM, Kamal Mittal via user wrote:
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
