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 =
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