Flink and Avro for state serialization

2021-06-10 Thread Yashwant Ganti
Hello all, We are running some Flink jobs - we wrote the job in Beam but are using the Flink Runner and are seeing the following error when restarting the job from a Savepoint Caused by: java.io.InvalidClassException: com.xxx.xxx; local class > incompatible: stream classdesc serialVersionUID =

Error restarting job from Savepoint

2021-05-26 Thread Yashwant Ganti
Hello, We are facing an error restarting a job from a savepoint. We believe it is because one of the common classes used across all of our jobs was changed but there was no *serialVersionUID* assigned to the class. There error we are facing is java.lang.Exception: Exception while creating