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.2] [FLINK-6025] [core] Add Flink's own JavaSerializer for Kryo serialization #3518

Closed
wants to merge 1 commit into from

Conversation

tzulitai
Copy link
Contributor

This is a backport of #3517 for release-1.2.

…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 to merge

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

@tzulitai The merge didn't close the PR :) I think the "this closes #xxx" thing only works for commits to master.

@tzulitai
Copy link
Contributor Author

Thanks for the reminder :-D

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
2 participants