I am getting the same error. Is there a way to retry/ignore instead of killing the job?
Jayant Ameta On Tue, May 22, 2018 at 7:58 PM gerardg <ger...@talaia.io> wrote: > I've seen the same error while upgrading Kafka. We are using > FlinkKafkaProducer011 and Kafka version 1.0.0. While upgrading to Kafka > 1.1.0, each time a server was restarted, an already running Flink job > failed > with the same message. > > Gerard > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
