flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Andrey Zagrebin <and...@ververica.com>
Subject Re: flink 1.4.2. java.lang.IllegalStateException: Could not initialize operator state backend
Date Thu, 16 May 2019 08:27:42 GMT
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 <anumodh@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/
>

Mime
View raw message