flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Bruno Aranda <brunoara...@gmail.com>
Subject Re: IndexOutOfBoundsException on deserialization after updating to 1.6.1
Date Wed, 17 Oct 2018 15:15:04 GMT

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?



On Wed, 17 Oct 2018 at 15:40 aitozi <gjying1314@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/

View raw message