Skip to content
This repository has been archived by the owner on Mar 3, 2023. It is now read-only.

Kryo serialization documentation needs to be updated #3606

Open
nicknezis opened this issue Aug 16, 2020 · 3 comments
Open

Kryo serialization documentation needs to be updated #3606

nicknezis opened this issue Aug 16, 2020 · 3 comments
Labels

Comments

@nicknezis
Copy link
Contributor

nicknezis commented Aug 16, 2020

It is not clear how to leverage Kryo serialization. There is no documentation for how to enable it or how to register serializers. I only found a single page on the website which says that Heron needs to be recompiled to add a custom serializer. This seems wrong.

Could someone more knowledgeable in the topic update this page? (Maybe @huijunw or @nwangtw ?)

Perhaps we should update an example topology in both Topology and Streamlet API examples?

@nicknezis nicknezis added the docs label Aug 16, 2020
@nwangtw
Copy link
Contributor

nwangtw commented Aug 16, 2020

An example could be good. "Heron needs to be recompiled" does seem a bit strange. Not 100% sure if it is needed though.

@huijunwu
Copy link
Member

huijunwu commented Aug 16, 2020

If your topology is having "Class is not registered" error with Kryo, you could solve it by adding the following line into your topology source code:

Config config = new Config();
config.registerSerialization(MyClass.class);
Submitter.submitTopology(... config, ...)

If this registration through config, it would need re-compiling the job. (this does not need re-compiling Heron)

@nlu90 thoughts?

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
Projects
None yet
Development

No branches or pull requests

3 participants