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/
