Hi Shai,
Flink’s Kryo registrations do not allow specifying the registration ID. They
simply start from ID 10 ( < 10 is reserved by Kryo for primitive types).
My guess at what you’re observing here is that when trying to deserialize your
newly changed class instance, it also tries to read the e
he default serializer?
From: Tzu-Li (Gordon) Tai [mailto:tzuli...@apache.org]
Sent: Sunday, June 04, 2017 3:28 PM
To: Shai Kaplan ; user@flink.apache.org
Subject: Re: KryoException: Encountered unregistered class ID
Hi Shai,
Flink’s Kryo registrations do not allow specifying the registration ID. They
si
interfere with
checkKryoInitialized() and set the default serializer?
From: Tzu-Li (Gordon) Tai [mailto:tzuli...@apache.org]
Sent: Sunday, June 04, 2017 3:28 PM
To: Shai Kaplan ; user@flink.apache.org
Subject: Re: KryoException: Encountered unregistered class ID
Hi Shai,
Fl
to be FieldSerializer.
From: Tzu-Li (Gordon) Tai [mailto:tzuli...@apache.org]
Sent: Tuesday, June 06, 2017 6:13 PM
To: user@flink.apache.org
Subject: RE: KryoException: Encountered unregistered class ID
StreamExecutionEnvironment.addDefaultKryoSerializer(YourClass.class,
TaggedFieldSerializer.class) should
e.org]
Sent: Tuesday, June 06, 2017 6:13 PM
To: user@flink.apache.org
Subject: RE: KryoException: Encountered unregistered class ID
StreamExecutionEnvironment.addDefaultKryoSerializer(YourClass.class,
TaggedFieldSerializer.class) should work.
You can also specify it dir
it.
From: Tzu-Li (Gordon) Tai [mailto:tzuli...@apache.org]
Sent: Tuesday, June 06, 2017 6:52 PM
To: user@flink.apache.org
Subject: RE: KryoException: Encountered unregistered class ID
Ah, I see what you’re trying to achieve. Then I don’t think that is possible
then, simply because Kryo doesn’t a
er.
From: Tzu-Li (Gordon) Tai [mailto:tzuli...@apache.org]
Sent: Tuesday, June 06, 2017 6:13 PM
To: user@flink.apache.org
Subject: RE: KryoException: Encountered unregistered class ID
StreamExecutionEnvironment.addDefaultKryoSerializer(YourClass.class,
TaggedFieldSerializer.class) should
