The stack trace shows that the state is being restored which has probably already happened after job restart. I am wondering why it has been restarted after some time of running. Could you share full job/task manager logs?
On Thu, May 16, 2019 at 6:26 AM anaray <anum...@gmail.com> wrote: > Thank You Andrey. Arity of the job has not changed. Here issue is that job > will run for sometime (with checkpoint enabled) and then after some time > will get into above exception. The job keeps restarting afterwards. > > One thing that I want point out here is that we have a custom > *serialization > schema* attached to *FlinkKafkaConsumer010*. After going through > FLINK-8836, I doubt if real issue is with kryo instances being shared > across > threads? > > Thanks, > > > > > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
