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.

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

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

Closed
wants to merge 1 commit into from

Conversation

tzulitai
Copy link
Contributor

This is a backport of #3518 for release-1.1.

…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.
@rmetzger
Copy link
Contributor

+1

asfgit pushed a commit that referenced this pull request Mar 13, 2017
…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.

This closes #3519.
@tzulitai tzulitai closed this Mar 14, 2017
@tzulitai tzulitai deleted the FLINK-6025-1.1 branch March 14, 2017 10:46
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
2 participants