I have a running pipe with Window State in a class say
Class A{
long a;
}
It uses the default KryoSerializer
I want to add a field to
Class A {
long a;
long b;
}
I need to suspend with SP and resume with the new version of Class A
Is there a definite way to do this. I tried
Class A {
long a;
@FieldSerializer.Optional("0")
long b;
}
but that seems to default to 0 , even when the Aggregation is putting in
values.
Could somebody give pointers as to how to solve this
Thanks a ton.
