instead of my Event class??
// also initialize fields for which the subclass serializer is not
responsible
initializeFields(target);
From: Nathan Yu
Sent: Friday, August 13, 2021 8:49 AM
To: JING ZHANG ; Schwalbe Matthias
Cc: user@flink.apache.org
Subject: RE
Does flink provide any hooks for objects before/after they are
serialized/deserialized?
Yea, it goes through many events from this input before the exception is
thrown. I don’t know how the input schema can change though, as the input is
always producing objects from the same class.
From: JING ZHANG
Sent: Thursday, August 12, 2021 10:22 PM
To: Nathan Yu
Cc: user
* Using local environment:
StreamExecutionEnvironment.createLocalEnvironment()
*Event is a POJO class, with int, double, enum, and String fields
*Unfortunately it's hard for me to reproduce in a small example, as it
seems to occur after 10e6+ events.
*Using flin
