Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[FLINK-6025] [core] Add Flink's own JavaSerializer for Kryo serialization #3517

Closed
wants to merge 1 commit into from
Closed

[FLINK-6025] [core] Add Flink's own JavaSerializer for Kryo serialization #3517

wants to merge 1 commit into from

Commits on Mar 12, 2017

  1. [FLINK-6025] [core] Add Flink's own JavaSerializer for Kryo serializa… 

    …tion

This commit adds a reimplemented JavaSerializer to be registered with
Kryo. This is due to a know issue with Kryo's JavaSerializer that may
use the wrong classloader for deserialzation.

Instead of registering Kryo's JavaSerializer for Throwables, it is now
changed to register the reimplemented JavaSerializer. Users who bump
into ClassNotFoundExceptions if they are using Kryo's JavaSerializer for
their own types are also recommended to change to Flink's JavaSerializer.
    @tzulitai
    tzulitai committed Mar 12, 2017
    Configuration menu
    Copy the full SHA
    3bc9011 View commit details
    Browse the repository at this point in the history