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.