Hi, Thanks for your reply. We are still trying to isolate it, because this job was using a more complex state. I think it is caused by a case class that has an Option[MyOtherClass], and MyOtherClass is an enumerator, implemented using the enumeratum library. I have changed that option to be just a Option[Boolean], and the failure seems not to happen anymore.
We may continue with the Boolean for now, I guess.... though this was not a problem in an earlier Flink version, possible Kryo change? Cheers, Bruno On Wed, 17 Oct 2018 at 15:40 aitozi <gjying1...@gmail.com> wrote: > Hi,Bruno Aranda > > Could you provide an complete example to reproduce the exception? > > Thanks, > Aitozi > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
