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
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
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
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
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
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
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
