Re: Avro state migration using Scala in Flink 1.7.2 (and 1.8)

2019-05-14 Thread Tzu-Li (Gordon) Tai
Hi Marc! I know we talked offline about the issues mentioned in this topic already, but I'm just relaying the result of the discussions here to make it searchable by others bumping into the same issues. On Thu, Mar 21, 2019 at 4:27 PM Marc Rooding wrote: > Hi > > I’ve been trying to get state

Avro state migration using Scala in Flink 1.7.2 (and 1.8)

2019-03-21 Thread Marc Rooding
Hi I’ve been trying to get state migration with Avro working on Flink 1.7.2 using Scala case classes but I’m not getting anywhere closer to solving it. We’re using the most basic streaming WordCount example as a reference to test the schema evolution: val wordCountStream: