Hi guys, Noticing similar things as Arvid mentions. I currently solved the issue by also supporting GenericRecords written and read with the old schema and parse them to the new schema myself. This at least gives us the evolution until state migration is there.
Thanks for your help! Cheers, Niels -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/