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 the above example to work, you need to include the necessary dependencies in your Maven project file (pom.xml). In the dependency section, add the following for Apache Thrift:
Please adjust the versions of both libraries as needed.
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.