Re: Trying to restart Flink jobs from savepoint with Avro Schema change

2018-04-05 Thread Till Rohrmann
Hi Dhvanan, could you provide us with a little example program to reproduce the problem? I've pulled Gordon in who might know more about the limitations of Avro schema evolution. Cheers, Till On Wed, Apr 4, 2018 at 2:36 AM, Dhvanan Shah wrote: > Hello! > > I have a Flink job that reads an Even

Trying to restart Flink jobs from savepoint with Avro Schema change

2018-04-03 Thread Dhvanan Shah
Hello! I have a Flink job that reads an Event Json stream and converts it to Avro format, and another job that reads this Event Avro stream does some processing and converts it to a Session Avro object. I have a change in schema in the Event and Session Avro object, and I want to restart both the