Hi, We are using Beamsql on our pipeline. Our Data is written in Avro format. We generate our rows based on our Avro schema. Over time the schema is changing. I believe Beam SQL generates Java code based on what we define as BeamSchema while submitting the pipeline. Do you have any idea How can we handle schema changes with resubmitting our beam job. Is it possible to generate SQL java code on the fly ?
Thanks
