3rd Party Serializers

Note that your custom serializer has to extend Kryo’s Serializer class. In the case of Google Protobuf or Apache Thrift, this has already been done for you:

For Google Protobuf you need the following Maven dependency:

If you register Kryo’s JavaSerializer for your custom type, you may encounter s even though your custom type class is included in the submitted user code jar. This is due to a know issue with Kryo’s JavaSerializer, which may incorrectly use the wrong classloader.

Please refer to FLINK-6025 for more details.